system.reactive

    0熱

    1答えて

    RX.netのDropQueueメカニズム

    私はRX.netで背圧問題を遭遇しましたが、解決策が見つかりません。私は観測可能なリアルタイムのログメッセージを持っています。私は、彼らがワイヤを介して送信される前に、logObservableからリアルタイムのログメッセージをシリアライズTCPインタフェースを介して公開する var logObservable = /* Observable stream of log messages */
    c# c#-4.0 system.reactive reactive-programming reactive 2017-10-28

    0熱

    1答えて

    HttpResponseMessageの観測可能性の中でAPIエラーをチェックし、どのようにチェックするのですか？

    私はAPI、C＃クライアントとそのAPIラッパーを持っています。私は柔軟な方法でAPIを扱うための拡張メソッドを含むクラスを持っています。 エラーを処理しようとしています。これらの拡張メソッドの一つがある：は public static IObservable<HttpResponseMessage> CheckForApiErrors(this IObservable<HttpResponseM
    c# .net observable system.reactive 2017-11-03

    0熱

    1答えて

    System.Web.HttpエンドポイントをIObservableにすることはできますか？

    System.Web.HttpエンドポイントをIObservableにすることはできますか？それはRouteやAcceptVerbsのような属性を使っている間に行うことができますか？ は基本的に、私は私が加入して反応性の拡張機能を経由して、それを処理していますので、IObservableストリームに次のコード例を作りたい： [Route("{id}")] [AcceptVerbs("GE
    c# system.reactive rx.net 2017-11-06

    2熱

    1答えて

    なぜ観測できません。最後に呼び出されていますか？

    私はFinallyメソッドを理解していません。このような状況では発火しません。 [TestMethod] public void FinallyHappensOnError() { bool finallyActionHappened = false; try { Observable .Throw<Unit>(new DivideByZe
    c# system.reactive 2017-11-10

    2熱

    2答えて

    どのようにRXでタイムアウトのシーケンスを達成するには？

    シナリオは次のとおりです。通信中のデバイスは、短時間のうちにサーバーにコールバックすると接続されたとみなされます。 このステータスを追跡する機能をカプセル化するクラスを作成したいと考えています。デバイスへの呼び出しで、タイムアウトをリセットする必要があります。コールバックで接続が確認され、ステータスがの場合はに設定し、コールバックがタイムアウトする場合はfalseに設定する必要があります。しかし、
    c# system.reactive .net-4.6 2017-11-15

    0熱

    1答えて

    Rx .Netを使用してデータパイプラインを作成しようとしています

    Rx .Netを使用していくつかのデータをパイプライン化しようとしていましたが、本当に苦労しています。 私はいくつかのデータを持つ保存されていないFoosのシーケンスを持っています。 Foosはバーのコレクションを作成します。バーが保存された後、バーにBarIdがある場合、FooのデータとBarのBarIdを使用してBazを作成します。 FooのすべてのバーとBazが作成されると、Fooのデータは
    c# system.reactive reactive-programming 2017-11-15

    2熱

    1答えて

    LatestFromで観測可能

    I kotlinの拡張関数として "FilterByLatestFrom"という擬似演算子を実装しました。 私は、この演算子を使用して次のコードを書いた： fun testFilterByLatestFromOperator(){ val observableA : Observable<Int> = Observable.fromArray(1,2,3,4,5,6,7,8,9,10)
    kotlin rx-java system.reactive publishsubject 2017-11-17

    0熱

    1答えて

    Observable.Timerの「進捗状況」を入手する方法はあります

    現在、私は、私は、これは時間が残り観測オフに基づいてカウントダウンを表示したいと思いますが、見つけることができません Observable.Timer(TimeSpan.FromSeconds(5)) .Subscribe(x => MessageBroker.Default.Publish(new Messages.Serve())); 予想通り、この作業を持っていますタイマー
    c# unity3d system.reactive 2017-11-20

    0熱

    1答えて

    アンドロイドクリーンアーキテクチャを使用する用途間でドメインデータを共有

    ドメインデータインスタンスをアンドロイドクリーンアーキテクチャプロジェクトに保存する必要があるのはどこですか？次の依存関係のルールを壊すことなく、すべてのユースケースによってインスタンスにアクセスできるようにする方法： ソースコードの依存関係は全く外側の円の中の何かについて何も知ることができる内側の円に内側と何も指すことができます。 現在、私たちは静的なデータを使用していますが、アプリケーションが
    android static system.reactive rx-java2 clean-architecture 2017-11-23

    0熱

    1答えて

    Rx.NETのRxJSスロットルタイムに相当する

    RxJS throttleTime相当のRx.NETを実装しようとしています（.NETでは実装されていません）。 throttleTimeは、Observableソースから値を出し、その後のソース値を無視して、このプロセスを繰り返します。 これは、発光するまでにある時間待つthrottleとは異なります。 throttleTimeが最初の項目を出してから、再度発光するまで待ちます。 これについては
    system.reactive 2017-11-23
最新の質問