RxJava：在不改變的情況下將回調變爲Observable

Question

我對RxJava有點新，但我正在努力學習它。在這種情況下，我有一個我不能改變的代碼，它使用了一個簡單的回調模型。但回調不直接調用，我不能參數化，但我仍然想使用Observables。基本的例子是，我打電話myFunc（）返回一個可觀察的，並開始後臺操作。然後，該後臺操作將在myCallback中返回。我想要的是然後調用onNext和結果然後我可以做一些結果。我只是不確定要使用什麼，這是否與受試者有關？

private void doStuff() { 
    myFunc().subscribe(new Action1<Object>() { 
     @Override 
     public void call(Object o) { 
      System.out.println("DO SOMETHING WITH THE RESULT"); 
     } 
    }); 
} 

private void myCallback(Object result) { 
    [SOMETHING].onNext(result); 
} 

private Observable<Object> myFunc() { 
    //Do stuff which will return in myCallback 
    return [SOMETHING] 
} 

Answer 1

看PublishSubject：

PublishSubject<T> subject = PublishSubject.create(); 
subject 
    // run in background 
    .subscribeOn(Schedulers.computation()) 
    .doOnNext(item -> doSomething(item)) 
    //make sure you log errors somewhere! 
    .subscribe(subscriber); 

訂閱建立後：

subject.onNext(item1); 
subject.onNext(item2); 
subject.onCompleted();