system.reactive

2熱

1答えて

IObservable <double>の値を変更する方法は？

私はRXで新しいです、今私は簡単なことをやろうとしています - 新しい値をIObservableに設定するだけです（私の場合Tは倍です）。どうやってするの？コンソールへ Subject<double> subject = new Subject<double>(); IObservable<double> observable = subject.AsObservable(); observa

c# system.reactive 2017-11-23

---

1熱

2答えて

ObservableとStateをペアにする方法は？

私はRx.Netを学んでいます。私は、多数の間隔で実行されるスケジューラを構築しています。アイデアは、私は間隔のコレクションとコマンドのコレクションを持っている、私はそれらを一緒にタプルし、結合された結果を購読している。各コマンドは、それぞれの間隔に関連付けられ、関連付けられて定義された間隔（ケイデンス）で実行されます。 私は間隔を一緒にマージすることができますが、私はこのコマンド（状態）をサブス

.net system.reactive reactive 2017-11-27

---

1熱

1答えて

observablesを動的に連結する

私は.NETのobservables/LINQを使用しています。 WebinarMedias = typesRepository.GetWebinarMedias(); これはIObservable<IList<Media>>次のようになります。私のアプリでは、私は、メディアオブジェクトのリストを取得します。私たちはビュー・モデルに入っています。サブスクリプションを行うビュー（ビュー・モデルで

c# linq observable system.reactive 2017-11-29

---

0熱

2答えて

Observable＃single（）とObservable＃toSingle（）の違いは？

私はこれらの方法に遭遇し、私がドキュメントから得たものから、ほぼ同じことをします。コードを見ると、彼らは明らかに違うことをしています。初心者からsingle()まではObservable（なぜ？）を返しますが、toSingle（）は実質的にSingleを返します。 反応的な世界に関する私の限られた知識は私に、なぜこれらの方法が両方とも存在するのか不思議に思っています。彼らはどのような違いがあります

java rx-java system.reactive reactive 2017-11-29

---

0熱

1答えて

バッファー文字列を1回だけ渡す方法はありますか。正規表現チェック

バイトバッファEncoding.UTF8.GetString(b.Buffer)の文字列表現は"Foo：Foo1"です。 文字列をRegexに対して解析し、次にRemoteDataという2つの異なるプロパティ（Message1とMessage2）でバインドしたいと思います。 public class RemoteData { private string _message1;

c# system.reactive 2017-12-03

---

-1熱

1答えて

返品の方法特定の種類のものを確認しますか？

Observable指定のジェネリックタイプを返す必要があります。しかし、zip演算子の後では、私はObservableしか得られません。 通常のキャスト修正方法Observable〜Observable<T>？おそらくこれにはいくつかのrx演算子がありますか？コードの 例： public Observable<Schedule> updateSchedules(final List<Schedu

java android system.reactive rx-java2 2017-12-12

---

0熱

1答えて

Rxのオペレータ：その他の観察からの最新の値がtrue

ある時はいつでも観察可能でください、私は次の意味を持つのRxオペレータを探しています： Observable<int> inputValues = …; Observable<bool> gate = …; inputValues .combineLatest(gate) .filter((pair<int, bool> pair) -> { return pair.se

system.reactive 2017-12-13

---

3熱

1答えて

IObservable、ランタイム例外の無効なキャスト

ストリーム/観測可能なオブジェクト内の特定のタイプのオブジェクトをフィルタ処理するヘルパーを作成しています。これは、要旨次のとおりです。 public interface IGameAction { } // Example action public struct OpenDoorAction : IGameAction { } // In Store.cs public Subje

c# generics casting system.reactive unirx 2017-12-17

---

1熱

1答えて

Rx.netと俳優モデル

私はメソッドからIObservable<T>を返す必要が状況を持っています。オブジェクトが変更されたときはいつでも、それはオブジェクトTの新しい値を返すことです。 オブジェクトが変更されたトリガーは、アクターシステムから来ます。私の例では、Proto.Actorを使用しています。私は「仕事」に例を得ている が、しかし、私はそれが正しくIObservableを実装していないと 退会等の適切な私の解決

c# async-await system.reactive 2017-12-19

---

0熱

1答えて

サブスクリプションの前にToPropertyを実行

ReactiveCommandには、出力として整数を生成します。 public ReactiveCommand<Unit, int> Calculate { get; } このコマンドからの最新の結果は、その出力はLatestValueに格納され、ObservableAsPropertyHelper private readonly ObservableAsPropertyHelper<int

c# .net system.reactive reactive-programming reactiveui 2017-12-24

---