asynchronous - オブザーバブルが作成された後に rxjava add items

Question

rxjava を使い始めたばかりで、行き詰まりました。rxjava を正しい方法で使用していない可能性がありますが、Observable作成後に項目を追加する必要があります。電話をかけるだけでサブスクライバーがそれらを受け取ることは理解していますがObservable.just("Some", "Items")、非同期タスクがあり、後でタスクが終了したときにアイテムを追加する必要がある場合はどうすればよいでしょうか? のようなものを見つけることができませんでしたObservable.addItems("Some", "More", "Items")

Answer 1

おそらく必要なのは件名です- http://reactivex.io/documentation/subject.html

これはObserverとObservableの両方のオブジェクトであるため、サブスクライブして新しいアイテムを発行できます。例えば ​​：

PublishSubject<String> subject = PublishSubject.create();
subject.subscribe(System.out::println);
subject.onNext("Item1");
subject.onNext("Item2");