RXJava。観察可能なままの人口

Question

私は以下のタスクを持っています：

私はいくつかのメソッドをいくつかのコレクションに追加する必要があるいくつかの方法があります。このメソッドは本当に頻繁に呼び出されるので、値のいくつかのカウントをバッファリングしてからコレクションに値を設定する必要があります。私は、次のコードスニペットがあります

observable 
     .observeOn(notFXThread) 
     .buffer(1, TimeUnit.SECONDS) 
     .subscribeOn(JavaFxScheduler.platform()) 
     .observeOn(JavaFxScheduler.platform()) 
     .subscribe(next -> next.forEach(resultList::addAll)); 

をしかし、私は2つの大きな問題を抱えて：

1. 私は私が観察初期化する必要があるか理解していないが。
2. populateメソッドをどのように実装する必要があるのか​​分かりません。

誰かが私を助けてくれることを願っています。

更新1： ObesrverはIDの作成または呼び出し元について何も知らない。オブザーバーにとっては、すべてがどのようにデータを取り込み、どのように実行する必要があるのか​​がわかっています。

Answer 1

私は次のようにルックスを初期化するので、ソリューション、PublishSubject観察可能なクラスに解決策を見つけた：

public void populate(final Long id) { 
    this.subject.onNext(id); 
} 

各this.subject.onNext(id)呼び出し全体に観察スタック：

this.subject = PublishSubject.create(); 
this.subject 
     .observeOn(scheduler) 
     .subscribeOn(scheduler) 
     .buffer(2, TimeUnit.SECONDS) 
     .subscribeOn(JavaFxScheduler.platform()) 
     .observeOn(JavaFxScheduler.platform()) 
     .subscribe(result::addAll); 

とpopulate(long id)方法は次のようになります。