reactive-programming

1熱

2答えて

私は最近Meteorを学び始めたので、Meteor経由でMongoを使う方法を学びましたが、私は理解できない何かがあります。私はしばしば例を見ています。SomeCollection.find().fetch()、私はfetch()が良いです？ docsで、彼らは言う：反応性の計算から呼び出された場合、一致した文書にレジスタの依存関係をフェッチことがSomeCollection変化のデータは、

0熱

1答えて

RxJS：配列内の要素の配列をフィルタリングする

私はflatMap,filter、およびあらゆる種類のRxJS演算子の組み合わせと並べ替えを多数試しましたが、私は問題を解決できないようです。私はタイプスクリプトでselectableを含むITagインターフェイスを持っています。私はITagsの配列のObservableを持っており、ITagsの配列の別のObservableを作りたいと思います。このselectableの性質は真です。ここで

0熱

1答えて

RxSwift、MVVM、Alamofire/Moya。区間を使用してティッカーを更新

現在、RxSwift（一般的にRx）を学習しています。最新のティッカー価格でUILabelを定期的に更新したいと思います。どのように.intervalとupdateTickerが毎回機能し、それに応じてUILabelを更新できますか？ ViewController.swift class ViewController: UIViewController { private let di

2熱

1答えて

Apache Kafka StreamsトピックへのKTablesのマテリアライズが遅いようです

私はkafkaストリームを使用しています。私はKTableをトピックに具体化しようとしています。これは動作しますが、30秒ごとに実行されるようです。カフカストリームは、KTableの現在の状態をトピックに具体化することをどのようにするかを決定しますか？この時間を短縮し、さらに「リアルタイム」にする方法はありますか？は、ここで私は30代に // Stream of random ints:

0熱

1答えて

リセット可能なタイマーでSystem.Reactive

IObservable.Timeout()を使用して、データソースが「オフライン」になったことを検出します。このデータソースは、ループ内で読み取られるシリアル接続です。読み取り操作は意図的にブロックされており、所定の期間データが受信されない場合は、操作をキャンセルしたいと考えています。それ以外の場合は、データを受け取るたびに、タイムアウトしたオブザーバブルにアイテムを生成させ、タイムアウトをリセ

0熱

1答えて

Observable：アレイのサブスクライバを更新していないと理解しています

私はobservablesの周りを頭で囲んでいます。私はオブザーバーで値が変わるときを知っています。観察可能なことは、すべての加入者に何か変わったことが通知されます。私は以下のコードがなぜ機能しないのか分かりません。私の要約は、配列に別の要素を追加すると、サブスクライバは新しい値を記録するか、すべての値をログに記録することです。誰かが理由を説明できますか？ import { Observable

1熱

1答えて

Ngrxストアとデータのリロードを防止する方法

現在、私はNgrxストアでAngularを学習しようとしています。サンプルを見て、私は次のことを思いついた。（完全なソースhttps://github.com/sebfischer83/Cointo/tree/master/angular/src）私は、ストアを含み、データベースからエンティティを読み込むコンテナコンポーネントを持っています。 @Component({ changeD

1熱

1答えて

繰延観察可能なコール

私は5つの観測を持っているgetObsX()の実装はRxNettyを通じてネットワーク呼び出しを行うことです Observable<String> obs1 = getObs1(); Observable<String> obs2 = getObs2(); Observable<String> obs3 = getObs3(); Observable<String> obs4 = getOb

-1熱

1答えて

特定の値を受け取ったときに観察可能から退会する

特定の値を受け取ったときに観察可能なものから退会するにはどうすればよいですか？このよう：あなたはtakeWhileオペレータ source.takeWhile(val => val === 'somethingSpecific'); または this.observable$ .takeWhile(val => val === 'somethingSpecific') .subscribe