rx-java2

0熱

1答えて

私はObservableを実装しています。ネットワークからファイルを複数の部分に分割してダウンロードするだけです。ここでは私の実装では、私は、このクラスのインスタンスを作成し、サブスクライブ方法からDisposableオブジェクトリターンでdisposeメソッドを呼び出しています私のコードで private static class MultipartDownloadObservable ext

2熱

1答えて

TestSchedulerが機能しない（Kotlin + RxJava2 + mockito）

私は以下のcallInitメソッドを検証する単体テストを書いたかったのです。しかし、私はラインがsubscribe(を保持するnullポインタの例外があります。私の質問は、以下のような方法でonnextとonerrorの条件をどのように検証するのですか？ override fun callInit() { val requestInit = RequestInit(os = "andro

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

2熱

2答えて

RxJava 2とAndroidでonError（）を遅らせる方法は？

アプリケーションのWebサーバーからデータを読み込もうとしています。また、操作の非同期性のため、完了までにどれくらい時間がかかるかを事前に知る方法はありません。操作が進行中であることをユーザーに警告するために、私はローディングインジケーターを使用しています。 fun loadData(){ showLoader() // show loading indicator Sin

0熱

1答えて

イベントが発生するたびにRxJavaがサブスクリプションメソッドで実行されます

サブスクライブでは長い操作を行いますが、ユーザーがボタンをクリックしたときに何か変更があるために長い操作を再度行うように通知します。ユーザーがボタンをクリックするたびに新しいサブスクリプションを作成する必要はありません。これを達成するための最良の解決策はどれですか？異なるスレッドでコードを実行するためにrxjavaの簡略化された方法を使用するソリューションを使用できるかどうかを知りたいと思いま

1熱

1答えて

Issue chaining flatMapCompletableの後に完了

それぞれEventについては、送信して検証する必要があります。 fun process(): Completable = eventsDao.findAll() .flatMapCompletable(this::sendEventToServer) .andThen(this::validate) //Error here fun send(event: E

0熱

1答えて

マップ内のonClickListenerを追加CustomView

他のフラグメントやアクティビティでマップを表示するためにカスタムビューを作成しました。しかし、Googleマップのようなフレームで簡単なクリックを取得したいと思います。誰も私を助けることができますか？は、カスタムビューがあります：私はXMLで使用する方法です public class MapView extends FrameLayout { private Subject<Go

0熱

1答えて

rxjava2を使ってバックグラウンドタスクを実行

私はちょうどRxJava2を学び始めました。私のアプリケーションでは、firebaseを照会して、データベースにいくつかのデータを保存する必要があります。事は私がRxJavaでこれをどのように使うべきか混乱しています。私は多くの解決策があることを知ったので、私は何をいつ、いつ使うのか混乱しています。 Singleオペレータを使用しようとしましたが、成功または失敗のいずれかを発行しますが、途中でスタ

-1熱

1答えて

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

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