rx-kotlin

1熱

1答えて

RxAndroidを使用してKotlin言語で観測可能なものをいくつかジップする方法

誰もが！私はいくつか問題があります。私はRxJava/RxKotlin/RxAndroidの初心者ですが、いくつかの機能を理解していません。例： import rus.pifpaf.client.data.catalog.models.Category import rus.pifpaf.client.data.main.MainRepository import rus.pifpaf.cl

0熱

2答えて

RxJava - バックプレッシャーキーボード入力？

ここに楽しいRxJavaの問題があります。 RxJavaバックプレッシャー演算子を使用して、Googleが検索ページで行うのと同じように、入力中に入力された入力をすばやく検索したいと考えています。私はBackpressureのドキュメントを見て、これを思いついた（私はRxJavaFX/RxKotlinFXを使ってJavaFXを利用している）。 val myControl: Node = ...

1熱

1答えて

Rx-Kotlin awaitTerminalEventは決してonCompleteを受け取りません

Rx-Kotlinで単体テストを行う方法をよりよく理解しようとしていますが、件名を「completed」に設定することができませんでした。その結果、私はいつも5秒のタイムアウトを待っています（onCompleteは即時にすべきです）。そしてassertCompleteで失敗します。 awaitTerminalEventの私の理解は、それがonCompleteが呼び出されるまでブロックする必要がある

1熱

1答えて

RxJava2でobservableで最後にN個のオブジェクトを取得します

Observablesにはいくつかの数値があり、最後のN個の要素を取りたいだけです。（単にRxJavaのラッパーである私はRxKotlinを使用しています）私は、次のしているコード：私は近いバッファオペレータが戻るが、私はこれを見たものに見えたとして val list = listOf(1,2,3,4,5,6,7,8,9,10) Observable.fromIterable(list)

0熱

1答えて

でサブスクライバに送信オブジェクトを繰り返して、同じオブジェクトをRxのサブスクライバに繰り返し送信することは可能ですか？ val exmp = listOf("А") var observable = exmp.toObservable() observable.subscribeBy( onNext = { it + "1"

1熱

1答えて

RxKotlin - TestSubscriber

をサブスクライブするときSingle.just（）は出さない私は何かが欠けてるように思える、これはそれがどのように動作するかであると思った。.. @Test fun singleCompletes() { val testSubscriber = TestSubscriber<Boolean>() Single.just(true) .subscribeOn

5熱

1答えて

Kotlinの高次関数とシングルメソッドのインタフェースでの動作は？

以前はRxJavaとKotlinを使っていくつかの問題を抱えていました。私はまだ私が困惑しているいくつかの興味深い発見をしました。私はRxJavaクラスも、Observableに拡張メソッドを追加しようとしていたRxJava public interface Func1<T, R> extends Function { R call(T t); } でシンプルなFunc1インタフ

1熱

1答えて

RuntimeExceptionベストプラクティスを処理する

RuntimeExceptionsはプログラミングエラーを示すはずで、私の観測所の中に何かRuntimeExceptionがスローされたときにアプリケーションがクラッシュするようにします。これを行うにはどのような方法が最適ですか？今私は、このソリューションを（それはKotlinだが、私はそれが理解できる願っています） fun <T> Observable<T>.subscribeCrashOnR

5熱

1答えて

RxAndroid - クリック時に観測再試行

AndroidアプリケーションでrxAndroidとrxKotlinを使用してネットワーク要求を非同期に処理しています。今すぐスナックバーボタンをクリックした後で失敗したネットワークリクエストを再試行したいと思います。私のコード今： val citiesService = ApiFactory.citiesService citiesService.cities() .subscr

3熱

2答えて

RxJava（Kotlin）、Observable.ambとPublishSubjectは発砲していません

15秒間隔で、または被験者refreshEventsSubjectにonNextを発射したときはいつでも、しかし成功することはありません。対象はそう private val refreshEventsSubject = PublishSubject<Long>() のように開始され、そして、我々は、我々は間隔からイベントごとに15秒を取得し、この Observable.merge(Observa