rx-java

0熱

1答えて

Observableで各アイテムを検証し、条件が失敗した場合にエラーを返す方法を教えてください。は今、私の中にifとswitchMapを使用していますが、このソリューションは非常にいいではないです： Observable.just(1, 2, 3, -1, 4) .switchMap(x -> { if (x >= 0) { return Observable

0熱

1答えて

ConnectableObservableを使用してプリフェッチし、別のサブスクライバで処理されたデータを使用する方法

私のアプリケーションでは、アプリケーションが起動するとすぐに大量のデータをロードする必要があります。また、一部のフラグメント/アクティビティでデータがロードされたときにイベントを受け取る必要があります。私はその目的のためにRxJava ConnectableObservableを使用しています。私はreplay()を使用しました。私は複数の加入者に同じデータが必要です。 Psudoコード：今、私

0熱

1答えて

Rxjava2 distinctUntilChanged（）が初めて初めて正しく動作しない

.distinctUntilChanged()を使用しようとしていて、初めて値の後にswitchmap()に値を渡しません。 RxTextView.textChanges(etUserQuery).debounce(300, TimeUnit.MILLISECONDS) .observeOn(AndroidSchedulers.mainThread()).filter(charSeque

0熱

1答えて

別の観測後に発光が始まり、その最初のアイテムが放出されます

私はこのような単純な使用法を理解することはできません。 2つの観測、AとB Aは、Bは、それが最初の項目だ発し、Bはアイテムを放出し続けることができた後ので、私はこれを必要としなくなっA. に影響を与えないはずである、項目を発光を開始考える発光を開始するためにBによって放出される最初の値が必要です。私はskipUntilとstartWithの両方を使用しないようにしました。

0熱

2答えて

：

を放射されたX項目よりも少ない場合、私はOBS1、obs2、obs3、...、それらのそれぞれ（のMongoDBデータベースからの）項目の数を発することができる観測のリストを持っているスイッチは、私が興味を持っています最初のN個のアイテムにのみ表示されます。私は、必要に応じてオブザーバブルのクエリが実行されるようにしたいと思います。つまり、たとえばobs1がNより大きい値を生成した場合、obs2

0熱

1答えて

facebook投稿添付ファイルを取得するNullPointerExceptionを返す

私はページ投稿添付ファイルを取得しようとしています。 { "attachments": { "data": [ { "media": { "image": { "height": 720, "src": "url", "width": 720 } } }

0熱

2答えて

2つの観測値が真となるまで待つ

ViewPagerに2つのFragmentsを保持するコンテナFragmentがあります。私はこれらの2つがデータを取得する準備が整うまで待つ必要があります。：私は、次のようにこれら二つを組み合わせたい var tab1ready = tab1fragment.viewReady() var tab2ready = tab2fragment.viewReady() ：私は私のコンテナFra

0熱

2答えて

Rxは数秒が経過するまでスキップします

私はX秒ごとに信号を放出し続けるPublishSubjectを持っていますが、Y秒後に放出される最初の項目についてのみ検討したいと思います。例観察Aは毎秒観察Bのみ-間にものを無視して、この "ダニ" 5秒ごとに発するべき "カチカチ" 発します。つまり、一定の時間が経過するまで、すべての項目をスキップします。これが原因デバウンスはは発光せずに5秒滞在する観察可能なオリジナルが必要です

0熱

1答えて

RxJava 2：Observable.create（）は、非同期コードがThread.sleep（）を使用して終了するまで待機します。

Observable.create(...)を使用して非同期コードをラップしています。非同期コードは5秒間 "アクティブ"にする必要があり、その後停止する必要があります。 Observable.<MyObject>create(emitter -> { // Some async code emitter.setDisposable(Disposables.fromRunn

0熱

2答えて

RxJavaを使用したアイテムのフィルタリスト

RxJavaでアイテムリストをフィルタリングするにはどうすればよいですか？私は、次のコードを持っているとloadData()はList<Chatroom>発する： repository.loadData() .subscribe(chatrooms -> { view.showData(chatrooms); view.showEmptyState(cha