問題タブ [rx-android]
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.
rx-java - subscribe が新しいスレッドで実行されないのはなぜですか?
私はこのようなタスクを持っています:
whereは、内部でマルチスレッド化せずに、同期的にメッセージを取得するgetMessagesFromDbメソッドです。subscribeOn メソッドの RxAndroid ドキュメントによると:
指定されたスケジューラでこのオブザーバブルにオブザーバーを非同期的にサブスクライブします
そして私の質問があります - データベース要求がメインスレッドで実行されるのはなぜですか? 非同期で行う方法は？
asynchronous - rxjavaは、異なるタイプのオブザーバブルをマージします
私はrxjavaが初めてです。異なるタイプのオブジェクトを放出する 2 つのオブザーバブルを組み合わせる必要があります。Observable<Milk>とのようなものObservable<Cereals>を取得しObservable<CerealsWithMilk>ます。このような演算子は見つかりませんでした。このようなことを行うrxの方法は何でしょうか? MilkとCerealsは非同期であることに注意してください。
java - RxJava 新しいオブジェクトをストリームに追加する
潜在的に存在するストリームに新しいオブジェクトを挿入しようとしています。
私がこれを持っているとしましょう：
ItemUtils.java
そして別のクラスで：
せっかちなユーザーがボタンを押すたびに、1 つの固有のアイテム ストリームにアイテムを挿入することは可能ですか?