asynctask를 Rxjava로 변환하려면 어떻게해야합니까?

Question

다음 2 개의 asynctasks를 rxjava로 변환하려고 시도하고 있지만 어떻게해야하는지 잘 모릅니다. 어떤 아이디어? :

new AsyncTask<Void, Void, Void>() { 
       @Override 
       protected Void doInBackground(Void... params) { 

        /* Shutdown video players */ 
        Set<Map.Entry<String, PlayerBundle>> entries = videoPlayerPool.entrySet(); 
        for (Map.Entry<String, PlayerBundle> entry : entries) { 
         PlayerBundle bundle = entry.getValue(); 
         bundle.player.release(); 
        } 

        /* Shutdown audio players */ 
        entries = audioPlayerPool.entrySet(); 
        for (Map.Entry<String, PlayerBundle> entry : entries) { 
         PlayerBundle bundle = entry.getValue(); 
         bundle.player.release(); 
        } 

        videoStreamer.stopStream(); 
        videoStreamer.release(); 

        audioStreamer.stopStream(); 
        audioStreamer.release(); 

        return null; 
       } 

       @Override 
       protected void onPostExecute(Void aVoid) { 
        cb.event(new Spin.Event<Void>()); 
       } 
      }.execute(); 

과 :

new AsyncTask<Void, Void, Void>() { 
      @Override 
      protected Void doInBackground(Void... params) { 
       Set<Map.Entry<String, Participant>> entries = pool.entrySet(); 
       for (Map.Entry<String, Participant> entry : entries) { 
        Participant participant = entry.getValue(); 
        participant.release(); 
       } 
       return null; 
      } 

      @Override 
      protected void onPostExecute(Void aVoid) { 
       cb.event(new Spin.Event<Void>()); 
      } 
     }.execute(); 

나는 이미 내 Gradle을에서 rxjava을 포함하지만,이

Answer 1

Observable.defer(new Func0<Observable<Void>>() { 
     @Override 
     public Observable<Void> call() { 
      /* Shutdown video players */ 
      Set<Map.Entry<String, PlayerBundle>> entries = videoPlayerPool.entrySet(); 
      for (Map.Entry<String, PlayerBundle> entry : entries) { 
       PlayerBundle bundle = entry.getValue(); 
       bundle.player.release(); 
      } 

      /* Shutdown audio players */ 
      entries = audioPlayerPool.entrySet(); 
      for (Map.Entry<String, PlayerBundle> entry : entries) { 
       PlayerBundle bundle = entry.getValue(); 
       bundle.player.release(); 
      } 

      videoStreamer.stopStream(); 
      videoStreamer.release(); 

      audioStreamer.stopStream(); 
      audioStreamer.release(); 

      return Observable.just(null); 
     } 
    }) 
    .doOnCompleted(new Action0() { 
     @Override 
     public void call() { 
      cb.event(new Spin.Event<Void>()); 
     } 
    }) 
    .subscribeOn(Schedulers.computation()) 
    .subscribe(); 

    Observable.defer(new Func0<Observable<Void>>() { 
     @Override 
     public Observable<Void> call() { 
      Set<Map.Entry<String, Participant>> entries = pool.entrySet(); 
      for (Map.Entry<String, Participant> entry : entries) { 
       Participant participant = entry.getValue(); 
       participant.release(); 
      } 
      return Observable.just(null); 
     } 
    }).doOnCompleted(new Action0() { 
     @Override 
     public void call() { 
      cb.event(new Spin.Event<Void>()); 
     } 
    }) 
    .subscribeOn(Schedulers.computation()) 
    .subscribe();