問題タブ [rx-kotlin2]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
android - RxJava2 および Kotlin : OnErrorNotImplementedException
KotlinでRxJava2を使用しています。理由はわかりませんが、常に次のエラーが発生します。
io.reactivex.exceptions.OnErrorNotImplementedException: 操作が実装されていません: 実装されていません
そのため、サブスクライバーに onError コールバックを追加しましたが、(onError 内で) このエラーが発生しました。
kotlin.NotImplementedError: 操作が実装されていません: 実装されていません
これは私のコードです:
私のプレゼンターで：
エラーを正しく処理するには? ありがとう
java - 最後のアイテムから特定の時間が経過した場合に値を発行する
Observable.create<Boolean> {emitter = it}いくつかの値をプッシュする observable: があります。そのエミッターに値がプッシュされずに特定の期間が経過するとすぐに、「false」値を公開したいと考えています。
RxJava/Kotlin 2 ではどのようにそれが可能ですか?
android - 条件付きループをRxJavaストリームに変換する
while ループでブロック操作を行うコードがあります (サーバーからデータをダウンロードします)。クライアントは、各ステップで返されるアイテムの数を知りません。N 個のアイテムがダウンロードされると、ループが壊れます。
downloadItemsブロッキング HTTP 呼び出しを実行し、リストを返します。downloadItemsここで、変更と新しい戻り値の型が であると仮定しましょうObservable<Item>。のようなことを実行せずに RxJava を使用するようにコードを変更するにはどうすればよいblockingGetですか?