rx-java

0熱

1答えて

メッセージを読み書きするメソッドがあります。 fun sendMessage(message: String): Observable<MESSAGE> { return readMessage().doOnSubscribe { socket.write(message) } } readMessage()ストリーム（socket.read()）からの高

1熱

1答えて

このケースでDisposableObserverを処理することが重要な理由

私はクリーンなアーキテクチャのアンドロイドプロジェクトに取り組んでいます。は、私は以下のクラスを持っている： public abstract class RxBaseInteractor<T, Params> { private final CompositeDisposable disposables; public RxBaseInteractor() {

0熱

1答えて

RxJava、2つの観測値を結合して2番目の観測値を出力する

2つのネットワーク要求、N1とN2を作成しています。これらは互いに依存しない2つの別々の要求です。 N1 Observable<GenresListResponse> genresListResponseObservable = tmdbInterface.getGenresList(BuildConfig.API_KEY); N2 Observable<NowPlayingMo

1熱

1答えて

RxJava非同期スレッド実装による競合状態の防止

私は、スプリングフレームワークStringRedisTemplateを使用して、複数のスレッドで発生するエントリを更新しています。このJSONエントリで public void processSubmission(final String key, final Map<String, String> submissionDTO) { final String hashKey = Stri

0熱

1答えて

RxJavaを使用した複数のユーザの戦略とデータフロー2

RxJava2を使用してこのタスクを正しく実装する方法を決定できません。問題は次のとおりです。私はAuidoRecordを使ってオーディオを録音しています。あなたは私が手動でリストに加入者を追加してい見ることができるように現在、私はその private class StreamAudioRecordRunnable extends Flowable<short[]> implements Ru

2熱

1答えて

subscribeWithでContextWrapperクラスを使用する方法

こんにちは私は、subscribeWithで改造エラー処理のためにContextWrapperを改造しました。私はhttps://blog.mindorks.com/rxjava2-and-retrofit2-error-handling-on-a-single-place-8daf720d42d6のような何かをしたい ApiHelperImpl().doServerLoginApiCall(em

0熱

1答えて

返された関数を渡した値を返す単数

特定の関数を呼び出し、関数が返す値で完了するSingleが必要です。次は似たものです： Single.fromCallable(this::func); それに伴う問題は、それは加入者が追加されるたびにfuncをこの::を呼び出すことです。したがって、this :: funcが3つ目のサブスクライバに3を返すコールをカウントすると、それは取得されます。これは問題として、this :: fu

0熱

1答えて

スプラッシュでデータを先取りする

フィードアプリを実装しようとしています。私は最大3秒間（フィードネットワークコールが完了したかどうかにかかわらず）実行され、ユーザにフィードが見える私のホーム画面に移動するスプラッシュアクティビティの新しいフィードをネットワークで呼びたいと思っています。私はスプラッシュで行った電話の応答をホームアクティビティに戻したいと思います。 RxJavaでRetrofitを使用してネットワークコールを行って