rx-java2

1熱

1答えて

RxJava2 createリスナーからFlowableを受け取り、最後にリスナーを削除します

私の使用例は、FirebaseデータベースでRxJava2を使用することに関連しています。私はDatabaseReferenceを持っており、値リスナーを登録することができます。私はこのような流動性の中にそれを変換することができます： disposable = Flowable.create<DataSnapshot>({ s -> dbRef.addValueEventList

1熱

1答えて

`zipWith`演算子の中で購読することはできますか？

私はRxJava2を使用していますが、私はその結果に応じて、異なるリストを返す条件を持っているzipWithオペレータはこの Flowable1 .doOnNext() .toList() .onErrorReturnItem() .zipWith(Flowable2 .toList() .onErrorReturnItem())

1熱

2答えて

rxjava2を使用して単一のデータベース行を照会

私はAndroidプロジェクトで初めてrxjava2を使用しており、バックグラウンドスレッドでSQLクエリを実行しています。しかし、単純なSQLクエリを実行し、レコードが存在する場合と存在しない場合を処理する最良の方法を考え出すのに問題があります。私が使用しているコードは次のとおりです。 public Observable<Record> createRecordObservable(int i

0熱

1答えて

観測可能なサポートレスキュープル

私はかなり基本的な質問であると私はしばらくの間苦労してきました。私はFlowableを持っています。これは、ネットワークからアイテムの束を取り出し、それらを放出します。 Flowable .create(new FlowableOnSubscribe<Item>() { @Override public void subscribe(FlowableEmitte

0熱

1答えて

オブザーバー<Void>のonNextとonCompleteは呼び出されません

私はRxJAVAの初心者です。私は別のスレッドに初期化ジョブを割り当て、完了したら私にアナウンスして作業を開始したいと思います。このObservableには放出するデータがないため、this topicで説明したVoid型を使用します。しかし、Void型を使用するとObserverのonNextとonCompleteは機能しません。代わりにStringを使用しようとしましたが、正常に動作します。私

0熱

1答えて

RXJavaで連続して電話をかける

ユーザーがアプリケーションを起動したとき（すぐに利用可能）、自分のデータベースから来ているデータを表示する必要があります。彼らが利用可能なので。私はそれをすることによって、これを試してみました： mDisposable = mRepository.getHighlights(forceReload) .subscribeOn(Schedulers.io()) .obser

0熱

1答えて

私は

、私はいくつかの場所のコレクションを意味 class Place { userId, price } 以下のダミーのようなデータのコレクションを持っているいくつかのデータを平均化するために、いくつかのRxJavaコードより優れた作りに滞在するのに長い時間を持っています。ユースケース：ユーザーIDとログインを持つユーザーがあります。平均的なプレースプライスをuser

0熱

1答えて

リフレッシュトークン要求でネットワークレイヤを設計するにはどうすればよいですか？

現在ログインしているユーザートークンの有効期限が切れ、リフレッシュトークンの呼び出しに成功するためのリクエストが最初に実行される必要があります。私の要求をどのように設計すればよいですか？ //Network Calls Observable<UserResponse> login(/*params*/); Observable<RefreshTokenResponse> refreshToken(

0熱

1答えて

AndroidでRXJava2を使用したネストされたリストの統合/平滑化

「単純な問題」に対するRXJava2ソリューションの策定には苦労しています。私は単純なユースケースを超えてRXJavaをよく経験していません。私はのように見えることContainerがあるとします。モデルの残りの部分は、このモデルのようなネストされたリストのシリーズです class Container { List<A> listOfA; } ： class Base {

2熱

1答えて

リサイクラーアダプターのRxjava2ビューのクリック

rxjava2と互換性のあるrxbindingsスナップショットバージョンを使用していますが、すべて正常に動作しますが、recyclerViewアダプター内のクリックイベントの処理方法はわかりません。私は "rxjava 1 way"を使用しようとしましたが、動作しません。 RxJava 1.0： class RecyclerAdapter ... { private final Pub