最後にObservable（Sequence）にプッシュされたアイテムを取る

Question

私はクラス内にIObservable<Item>を持っており、与えられた時刻に最後のアイテムを観測可能にプッシュする読み取り専用プロパティを公開したいと思います。したがって、Itemの単一の値を提供します。

値がプッシュされていない場合は、デフォルトのの値を戻す必要があります。

私は観察可能なものを購読したり、 "バッキングフィールド"を持たなくてもこれを行うことができますか？

Answer 1

：

観察できるが、それは、より論理的な概念ですが、物理的な「もの」ではありません。 RxはしばしばLINQと比較され、それはかなりの時間の公正な比較です。 LINQの列挙型は、学習目的でListに似ています。

しかし、Rx側では、Listと同等のものはありません。観測可能なのは一時的なデータ構造であり、すべての演算子はこの過渡状態を処理します。あなたが永続的な状態を探しているなら、あなたはRxを離れることになります。

このように言えば、ある種の状態に観察可能なものを変換することはよくある問題です。あなたに役立つパッケージがいくつかあります：ReactiveUIがおそらく最もよく知られています。 ReactivePropertyは別のものです。これらのパッケージには欠陥がありますが、あなたに役立つかもしれません。

あなたは、単にバッキングフィールドを取得する簡単な方法を探しているなら、バッキングフィールドをボイラーは、めっきなしで、これは動作します：

public static class ReactivePropertyExtensions 
{ 
    public static ReactiveProperty<T> ToReactiveProperty<T>(this IObservable<T> source) 
    { 
     return new ReactiveProperty<T>(source); 
    } 

    public static ReactiveProperty<T> ToReactiveProperty<T>(this IObservable<T> source, T defaultValue) 
    { 
     return new ReactiveProperty<T>(source, defaultValue); 
    } 
} 

public class ReactiveProperty<T> : IDisposable 
{ 
    private IObservable<T> Source { get; } 
    private IDisposable Subscription { get; } 
    public T Value { get; private set; } 

    public ReactiveProperty(IObservable<T> source) 
     : this(source, default(T)) { } 

    public ReactiveProperty(IObservable<T> source, T defaultValue) 
    { 
     Value = defaultValue; 
     Source = source; 
     Subscription = source.Subscribe(t => Value = t); 
    } 

    public void Dispose() 
    { 
     Subscription.Dispose(); 
    } 
} 

使用例：

var ticker = Observable.Interval(TimeSpan.FromSeconds(1)) 
    .Publish().RefCount(); 

var latestTickerValue = ticker.ToReactiveProperty(); 
Console.WriteLine(latestTickerValue.Value); 
await Task.Delay(TimeSpan.FromSeconds(1)); 
Console.WriteLine(latestTickerValue.Value); 
await Task.Delay(TimeSpan.FromSeconds(3)); 
Console.WriteLine(latestTickerValue.Value); 

Answer 2

熱いと見なします。

はobservable = source.Replay(1); observable.Connect();

のために価値を提供します

public int Value => observable.Take(1).Amb(Observable.Return(defaultValue)).Wait();

これは何の値がプッシュされていない場合のデフォルト値を返します。

リアクティブから状態への移行が必要なので、バッキングフィールドはひどいオプションではありません。あなたは購読したくないと言いましたが、何かを観察することを言いました：何か、どこかで購読する必要があります。ただ、少しここでアスティの答え@補うために、そしておそらくあなたの欲求不満のお手伝いを