rx-java

0熱

1答えて

私は3つの編集テキストをお互いに依存しています。私に説明させてください：ユーザがedittext1に値を入力すると、edittext2とedittext3の値が計算されます。 edittext2とedittext3についても同じことが起こります。つまり、1種類のデータを持つユーザーは、2種類の他の種類のデータを計算できます。しかし、データ1では、結果2のデータ2を計算できますが、2でXを入力

0熱

1答えて

oncompleteのみが呼び出されたときのscala rx observables上のマッピング

私はscala observablesをcouchbaseから取得するためにmap、flatMap、zipを使用して結果を変換しています。問題は、アイテムがcouchbaseに存在しない場合、たとえば.zipはonCompleteだけ呼び出されないことです。例： import rx.lang.scala._ def getIdsWithValues(ids: Seq[String]): Map

0熱

1答えて

RxKotlin - ダイナミックオブザーバー配列

私はレトロフィット2と一緒にをRxKotlinを使用している私は、単一の操作にオブザーバーの動的なリストを持っているどのように数字をしようとしています。最初の観察者が操作をトリガーする必要があり、操作が完了/完全な操作たらを失敗するまで、すべての追加のオブザーバーは待つべき、私はデータ操作（キャッシュ/メモリ内ストア）にする必要があり、その後、すべての通知しますオブザーバー。ここに私がやっ

1熱

1答えて

観測値から最新の値を得る方法

1秒間隔後に1つのアイテムを放出するタイマーがあるとします。私はそれを購読して10秒間実行したいと思います。 10秒後に私はそれから退会し、コードの他の部分からの最後のemmited値にアクセスできるようにしたい。コードのohter一部から最後emited値を取得する方法はあり @Test fun testMeasuretime(){ val emitter = Observabl

0熱

1答えて

gRPCのコンテキストから別のスレッド/ threadPoolにtraceIdを渡すには？

grpc-javaを使用していて、A、B、Cの3つのサービスを持っています。サービスAを呼び出し、サービスAがBとCを呼び出します。BとCの呼び出しでHystrixを使用しています。別のサービスを呼び出す。 traceIdの周りを通過するClientInterceptorsとServerInterceptorsがあります。コンテキスト内のtraceIdsを見ることができ、gRPCワーカースレッドで

1熱

1答えて

flatMap演算子で正しく照会する方法は？

サーバーからjson形式のチャットのリストを取得します。私はそれらをクラスChatsModelにプッシュします。このクラスにはuserIdというフィールドがあります。そのチャットにはそのユーザーのuserIdがあります。ユーザーに関するその他の情報はありません。そして、タイプだから、UserMessagesResponse の利用者については、一つのフィールドはuserMessagesRespon

0熱

1答えて

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

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

0熱

2答えて

RxJava - イベントが発生するたびにリクエストしてからリクエストします

私は共通のメカニックがいることがわかりました。それを達成するためのより良い方法があるのだろうか。 Observableを購読しているときにネットワークリクエストを行い、特定のイベントが発生するたびに再度リクエストするようにしたいので、オブザーバブルは無限になります。たとえば、私はgetScreenData（）リクエストを持っているとしましょう。私はそれを呼び出す画面を開いたときに、relogin

0熱

2答えて

Hystrix ObservablesでtraceIdsを渡すには？

私は複数のサービスを持っていますが、その中にはHystrixのHystrixObservableCommandを使って他のサービスを呼び出すサービスや、HystrixCommandを使用するサービスがあります。呼び出し元のサービスからtraceIdをHystrixObservableCommandのオブザーバブルに渡すにはどうしたらいいですか？また、フォールバックが呼び出された場合に渡されるように