rx-java

0熱

2答えて

Observable＃single（）とObservable＃toSingle（）の違いは？

私はこれらの方法に遭遇し、私がドキュメントから得たものから、ほぼ同じことをします。コードを見ると、彼らは明らかに違うことをしています。初心者からsingle()まではObservable（なぜ？）を返しますが、toSingle（）は実質的にSingleを返します。反応的な世界に関する私の限られた知識は私に、なぜこれらの方法が両方とも存在するのか不思議に思っています。彼らはどのような違いがあります

0熱

1答えて

rxjava2プロデューサ - コンシューマ、 'downstream'リクエスト1、 'upstream'で1を送信

rxjava2を使用したいと思うのは、ダウンストリームリクエスト1、 flatMapまたはobserveOnにはデフォルトのバッファサイズ128があるので、バッファサイズは1に設定されていますが、それも機能しません。私はs.request(1)一度だけ呼び出すため flatMap:1 flatMap:2 onNext:1 flatMap:3 予想される出力、：： Flowable.def

0熱

1答えて

RxJavaフィルタリング後の次の項目を取る

私は順序付きリストを持っており、条件に基づいて次の項目を取得しようとしています（つまり、項目を見つけて次の項目だけを取得するまで）。 List<Integer> items = Arrays.asList(new Integer[]{1,2,3,4,5}); Observable.from(items).filter(i -> i == 3) //.something here to get 4

0熱

1答えて

MVVMパターンのRXを使用してSpinnerにアイテムを動的に配置しますか？

私はRxjavaでMVVMを使用していますが、これはRxjavaを初めて使用するときです。Spinnerのレスポンスを使用して項目を取り込みたいと思います。スピナーはどのように動的に配置されますか？ ApiInterface @GET("client") Observable<List<ClientListApi>> clientListApi(); RegisterFragment

0熱

1答えて

接続可能なobservableでのRxJava再接続が機能しない

こんにちは。私はRxJavaで何らかのMVCを作ろうとしています。したがって、考えられるのはであり、常に一定のサブスクリプションを作成し、それは常に観察されるにサブスクライブされます。また、この観察可能な部分は、ネットワークコールなど、いつでも再実行することができます。私は、この機能をテストするには、このコードを試してみました： class Main { companion obje

0熱

1答えて

IncompatibleClassChangeError：クラス 'java.lang.VirtualMachineError'がインターフェイス 'java.lang.CharSequence'を実装していません

私のコードで奇妙な問題が発生しており、何か起こっていることを説明できません。それはマシュマロではなく、これをより奇妙にするノーガットではクラッシュしている。エラーが発生する行を指すことはできますが、エラー自体は明確ではありません。私は何がクラッシュしているのか、それを防ぐ方法はわかりません。ここに詳細があります：サーバーに電話をかけようとするとクラッシュします。これを行うには、Retrofit

-1熱

1答えて

RxJava2のカスタムObservableでObservableオブザーバの通知を受け取る方法

In this thread、アンサブスクライブ後にリスナーをクリーンアップして削除できるように、unsubscribeイベントを監視する方法について質問があります。しかし、RxJava2では、上記のスレッドはもはや動作しません。 def myObservable = Observable.create({ aEmitter -> val listener = {event ->

0熱

1答えて

BLEデバイスwriteCharacteristicが失敗する

BLE血圧デバイスからデータを取得しようとしています。教師は、デバイスが接続されるたびに日付と時刻を同期させる必要があると言います。コード： interactionSub = Observable.concat( deviceConnection .writeCharacteristic(ReactiveBluetoothHelpers.DATE_TIME_CHARA

0熱

1答えて

シングルとRxjavaは改造要求を実行しませんか？

こんにちは私はretrofitとrxjavaを使って簡単なリクエストを作成し、レスポンスを返しますが、リクエスト自体を作成しているか、レスポンスを返すようですか？これは私の改造コードです：ここで public class Controller public Single<List<ListItems>> getItems() { return apiCall().getItems