rx-kotlin

0熱

1答えて

私は理解しがたい奇妙な問題に遭遇しました。私はcallableからobservableを生成するいくつかのコードを書いています。それはうまくコンパイルされますが、スケジューラを指定するとすぐに戻り型が変更され、コンパイルされません。ここでは（コンパイル）subscribeOnのないコードです： /** * Gets all the room bookings for the specified

1熱

1答えて

必要<Object>と見つかりました<Object>？コンパニオンオブジェクトのgetInstanceメソッドで

class TaskRepo(taskData: TaskData) { companion object { private val repoByTask: LRUMap<String, OrderFormRepo> = LRUMap(2, 10); fun getInstance(taskData: TaskData): OrderFormRepo { i

-4熱

3答えて

kotlinプログラミング言語で以下に述べるようなループを作るにはどうしたらいいですか？私は、forループを使用してkotlinでそれを行うことができますどのように

？ for (double i = 0; i < 10.0; i += 0.25) { System.out.println("value is:" + i); }

0熱

1答えて

RxJavaストリームの途中で非同期操作を条件付きで追加するにはどうすればよいですか？ここ

は、私がasyncOperation()への呼び出しに絞ると、火災にそのコールバックのストリーム待ちの残りの部分を作るにはどうすればよい makeServerCall() .doOnNext { doStuff(it) } //TODO: if it == 0, call asyncOperation() and wait for

0熱

1答えて

stream1を2回購読する.zip（stream1、stream2、BiFun）を避けるにはどうすればよいですか？

私はいくつかの複雑なデータでアンドロイドのfirebaseを使用しています。私は参照を保存する必要があり、私は私のzip操作、または私はRX全体を処理している方法で問題を取得しています。 Bについての情報を含む新しいA objectを作成し、についての情報を持つようにB objectを更新したいとします。 firebase操作が両方成功しているとき、私はlogcatを経由する場合はSingle<A

0熱

1答えて

一般観測可能からPublishRelayを購読するには？

Kotlinコード： fun <T> Observable<T>.circuitBreaker(): Observable<T> { val relay = PublishRelay.create<T>() this.subscribe(relay) return relay.toFlowable(BackpressureStrategy.LATEST).toObse

0熱

1答えて

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

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

1熱

1答えて

次の例が期待どおりに機能するようになってしまった。zipとcombineLatestを使用して試したところ、withLatestFrom私が欲しいもの @Test fun thereCanBeOnlyOne() { val s1 = BehaviorSubject.create<Int>() val s2 = BehaviorSubject.create<Int>()

0熱

1答えて

Spring 5とKotlin 1.1コルーチン：タイプrx.Schedulerが存在しない

私はSpringコンテキスト5.0.0.RELEASEでKotlin 1.1.4-3を使用しています。開始プロジェクトで私はこのエラーを取得する： org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'coroutineAnnotationBeanPostP

0熱

1答えて

RxJava2で例外をスキップする方法はありますか？

私はこのようなデータの流れがあります。 Observable .fromFuture( CompletableFuture.supplyAsync { // First remote call returns Future<List<Type>> listOf(1, 2, 3, 57005, 5) }, Schedulers.computa