rx-java2

1熱

3答えて

RxLifecycleを廃棄する前に、観測可能な状態でソケット接続を閉じる必要があります。どうやってやるの？

1熱

1答えて

rx-java2 Schedulers.io（）スチールはmainThreadのメソッドを呼び出します

Rxの方法でデータベースからデータを取得しようとしています。は、これは私が override fun onStart() { super.onStart() disposable.add(presenter.getAllBooks() .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedul

0熱

1答えて

RxJavaオペレータDebounceが機能しない

私はAndroidアプリケーションでプレースオートコンプリートを実装したいと思いますが、これはRetrofitとRxJavaを使用しています。私はユーザーが何かを入力した後に2秒ごとに応答したい。私はこれに対してdebounce演算子を使用しようとしていますが、動作しません。それはすぐに結果を私に与えています。 @BenPコメントで言うように mAutocompleteSearchApi.get(

0熱

1答えて

返されたobservableを新しいものと置き換える方法RxJava2

すぐに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

1熱

1答えて

doAfterTerminateとdoFinallyの相違点

RxJava 2の演算子 "doAfterTerminate"と "doFinally"の違いは誰にも分かりますか？

0熱

1答えて

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

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

0熱

1答えて

レルム - 反応拡張RxJava2

私はRxJava2と一緒にレルムを使用しています。 Realmのインスタンスはプログラマによって閉じられるか、自動的に閉じられる必要がありますか？私はこのチェーンに問題があります。 return Observable.merge( getEvents .toObservable() , mChangeEventsNotification

0熱

1答えて

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

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

1熱

2答えて

RxJava2 toList（）は決して放出しません

私はうまくいきません。私はRoomを使用してテーブルからすべての行をリストとして取得し、それぞれを何かにマップしてリストを作成し、そこから続行しません。 storedSuggestionDao .getSuggestionsOrderByType() //Flowable .doOnNext(storedSuggestions -> Timber.e("storedSugges