私は以下のタスクを持っています:RXJava。観察可能なままの人口
私はいくつかのメソッドをいくつかのコレクションに追加する必要があるいくつかの方法があります。このメソッドは本当に頻繁に呼び出されるので、値のいくつかのカウントをバッファリングしてからコレクションに値を設定する必要があります。私は、次のコードスニペットがあります
observable
.observeOn(notFXThread)
.buffer(1, TimeUnit.SECONDS)
.subscribeOn(JavaFxScheduler.platform())
.observeOn(JavaFxScheduler.platform())
.subscribe(next -> next.forEach(resultList::addAll));
をしかし、私は2つの大きな問題を抱えて:
- 私は私が観察初期化する必要があるか理解していないが。
populate
メソッドをどのように実装する必要があるのか分かりません。
誰かが私を助けてくれることを願っています。
更新1: ObesrverはIDの作成または呼び出し元について何も知らない。オブザーバーにとっては、すべてがどのようにデータを取り込み、どのように実行する必要があるのかがわかっています。
'populate'でアイテムを直接返すようにして、RxJavaにコレクションをさせる必要があります。しかし、これは、反応的なストリームが 'id'がどのように生成され、' populate'メソッドを呼び出すかを理解しなければならないことを意味します。あなたはあなたの質問にこれらを追加できますか? –
@ TassosBassoukos、返信ありがとう。私はあなたの条件の質問を更新しました。しかし、私はすでに解決策を見つけましたが、私は自分の評判が増した理由のために、今すぐ投稿するのが良いアイデアであるとは確信していません。 – ZhenyaM