ConnectableObservableのサブスクライバのタスクの完了を待ちます

複数のサブスクライバを経由してリソース集約型のタスクを実行するオブザーバブルを作成しました。残念ながら、connect（）は、サブスクライバがタスクを完了できないソースを同期的に待っているだけです。 ConnectableObservableのサブスクライバがタスクを終了してから実行を続けるのを待つ方法はありますか？ConnectableObservableのサブスクライバのタスクの完了を待ちます

出典

2017-09-20 Anatoly Kislov

サブスクライバから.observeOn（）を削除して解決しました。このように.connect（）でマルチスレッドを使用する方法があるのだろうかと思います。 –

mayサブスクライバの1人は.observeOn（Schedulers.io（））を含み、指定したスケジューラに送信します。おそらく.connect（）は現在のスレッドを待つだけです。それを削除すると問題が解決されます。

出典

2017-09-20 01:07:59

ConnectableObservableのサブスクライバのタスクの完了を待ちます

答えて

関連する問題