rx-java

0熱

1答えて

すぐにobservableを返す必要がある場合がありますが、このobservableを別のものに置き換えます。ここでは例 private Flowable<byte[]> mFlowableStream = Flowable.empty(); @Override public Flowable<byte[]> startStreamRead() { bindTo

0熱

2答えて

単位テスト遅延があるRxjava観測値

実際に遅延時間を待たずに遅延放出を持つObservableのユニットテストができたいと思っています。これを行う方法はありますか？現在、CountDownHatchを使用してアサートを遅延させていますが、正常に動作しますが、テスト実行時間が長くなります。例： val myObservable: PublishSubject<Boolean> = PublishSubject.create<Boo

0熱

1答えて

リアクティブ・インタフェース・リポジトリの適切なテストの記述方法イベントが発生したときだけオブザーバブルを返す方法、そのイベントをトリガーする方法

私はリアクティブ・リポジトリの正しいテストを書こうとしています。私は実際に場所の変更を聞きたいだけでなく、ちょうど作成されたカスタムロケーションで新しい場所の変更を複数回呼び出すだけです。ここではリポジトリと収集場所のためにその機能である：ここでは interface RxLocationRepository { @SuppressLint("MissingPermission") fun

0熱

1答えて

オブジェクトに追加の内容を読み込んで別のオブザーバブルで変換するobservableを呼び出す方法は？

私はfirebaseデータベースからすべてのCollectionItemVOをロードし、このMyCollectionInteractorています public interface MyCollectionInteractor extends BaseInteractor{ Single<List<CollectionItemVO>> load(); } CollectionItem

1熱

1答えて

最初の呼び出しが終了するまでrx java observableが再度実行されないようにする方法

同期アダプタに同期があります。同期が呼び出されたら、最初の同期から応答を処理するまで、OSからその同期アダプタへの他の呼び出しをブロックする必要があります。 Single上で.blockingGet（）を呼び出すとそのトリックを行うと思ったが、そうはしなかった。シングルをもう一度コール/購読する前に、シングルで処理されているすべてのコードが終了していることを確認するにはどうすればよいですか？ @O

2熱

1答えて

LatestFromで観測可能

I kotlinの拡張関数として "FilterByLatestFrom"という擬似演算子を実装しました。私は、この演算子を使用して次のコードを書いた： fun testFilterByLatestFromOperator(){ val observableA : Observable<Int> = Observable.fromArray(1,2,3,4,5,6,7,8,9,10)

3熱

2答えて

RxJava zipWith Androidスタジオ3.0を使用しているKotlinでIDEエラー

いくつかのアイテムを放出するObservableを作成し、Interval Observableのオブジェクトのリストを含むObservableを作成して、最初のObservableのアイテムがある程度遅れて放出されるようにします。ここは私の実装です。しかし、赤zipWith演算子でIDE、Androidのメーカー3.0下線 val just1 = ArrayList<SomeClass1>()

1熱

1答えて

2つのInfiite Observableストリームをシミュレートする方法と、それらをマージして10秒ごとにバッファリングする他のObservableを持つ方法はありますか？

いくつかのオブジェクト（同じParentオブジェクトを拡張している）を放出する2つの別々のストリームをマージして、バッファオペレータを使用してバッファリングし、10秒後に収集したデータを放出することをシミュレートできます。このマージ/バッファは、2つの分離されたストリームからのエミッションがあるたびに常に呼び出されるように、このメカニズムを無限にしたいと考えています。ここでは、私がこれまで何をや

0熱

1答えて

RxJavaボタンが押されたときに繰り返されるイベントを生成するために観測可能

私は、ユーザがビューを押し続けている間に繰り返しイベントを生成するオブザーバブルを作成しようとしています。下のコードはうまく動作しますが、初めての場合（ユーザーがボタンをもう一度押すと、何も起こりません）。私は間違って何をしているのかアドバイスしてもらえますか？これには何がベストプラクティスですか？ val touches = RxView.touches(previousButton) tou

2熱

2答えて

rxjava観測を作成する

どのようにして画像のような観測を作成できますか？ Click to see the picture クリックイベント1と3と4を取得し、1、2、3が非常に近いので、2を取り除きたい（<の間に200ミリ秒）。クリックイベントがある場合1,2,3,4,5,6 ................ 7,8,9 .......... 10 、私はわずか1,6,7,9,10を取得したい。 1,2,3,4,5,