reactivex

2熱

1答えて

RxJava - 「一つだけ発光を一度に観測可能なチェーンを走行させている...」

私はここにブログの記事を読んでいる：http://tomstechnicalblog.blogspot.com/2016/02/rxjava-understanding-observeon-and.html それはそのありませんと言われてどのスケジューラを購読しているのかによって、一度にObservableチェーンの上を移動できるのは1回だけです（）。以下は、次の発光を開始する前に、放射源

2熱

2答えて

ObservableにサブスクライブするBehaviorSubjectを作成するにはどうすればよいですか？

私はBehaviorSubjectを返さなければならない関数を持っています。対象は、の最新バージョンを返すように意図されてProfile （ユーザー）Profileは3人のメンバーへの参照が含まちょうどPOJOです： - Userを、 - そのユーザーのMeasurementList、 - とDeadline。これらのプロパティのうちの2つは、改造呼び出しによって取得され、そのうちの1つはすでに

1熱

1答えて

Observable Intervalを遅滞なくすぐに開始するにはどうすればよいですか？

私は私の観察可能なものをすぐに、そして毎秒もう一度発射したい。 intervalは直ちに発射されません。私はthis questionを見つけました。これはstartWithを使用していましたが、すぐに発火しましたが、最初に重複した項目があります。 Rx.Observable.interval(1000).take(4).startWith(0).subscribe(onNext); http

-1熱

1答えて

RxJsは、内部のタイトルを説明するために

少し疑似コードを下に通過せずにサブスクライブします。これまでのところ、私はobservableを拡張しようとしましたが、私が行った場合、observable内の演算子をオーバーライドする必要があるように見えます。ほとんどの場合、イベントにメタデータを提供したいと考えています。これは外部的に使用するライブラリなのでmyObjectを渡したくないので、私は自分のコードベース内のobservabl

-1熱

2答えて

ReactiveXプログラミングについての問い合わせ

私はswift 3.0でプロジェクトを完成させました。すぐにrxSwift、rxCocoaのReactiveXフレームワークで更新したいと思っています。私の主張は、私が反応的なことを学んでいることです。リアクティブに時間を費やすことは効果がありますか？コードが大幅に短縮されるため、アプリケーションのパフォーマンスが向上しますか？ ReactiveXの将来について個人的にはどう思いますか？

0熱

1答えて

map v.s.約束は

に関与しているときflatmap私はオペレータmap v.s.を勉強していますflatmap 観察可能なチェーンに約束を追加する方法。次に、var sourceの4つの異なるバージョンを作成しました。バージョン1と3は期待通りに動作し、バージョン2と4は奇妙な動作をします。私のコードも=>js bin に追加されましたが、誰かが私のコードが間違っているものを教えてもらえますか？おかげで、

2熱

1答えて

Rx.Subject.create <a href="https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/subjects/subject.md" rel="nofollow noreferrer">API documentation</a>で（オブザーバ、観測可能）混乱

はそれが引数観測者（オブザーバー）を言います。 observable（Observable）：被験者から送信されたメッセージを購読するために使用される観察可能なもの。しかし、それにオブザーバーは、被検体から放射されたメッセージを処理/受信されることになって、そして、観察は、対象が加入されるものです後方概念ではありませんか？ API docとgetting started with subje

1熱

1答えて

KotlinプロパティObservable

ReactiveUIでは、whenAny()を使用して、プロパティまたはプロパティのグループから観測可能なオブジェクトを作成できます。どのように私はKotlinで同様のことを達成できますか？

0熱

1答えて

なぜ複数のRXJavaオブザーバブルで並列実行が行われないのですか？

私はRxJavaに新しいですし、リンクから複数の観測のための並列実行の例を実行しようとしていた。 RxJava Fetching Observables In Parallel 上記のリンクで提供された例は、並行して観測を行っているが、私はスレッドを追加したとき。 sleep（TIME_IN_MILLISECONDS）forEachメソッドでは、システムはObservableを一度に1つずつ実行し

1熱

1答えて

配列をflatMapの項目のシーケンスに変換する

RxJSでは、ある点にある配列を配列内の項目のシーケンスに変換したいと思います。私はそれを行うには、2つの方法が見つかりました：オプション1 & 2、私は推測し、同じことを実行します。 const obj = { array: [1, 2, 3, 4, 5] }; const observable = Observable.of(obj); // Option 1 observable.