Кэширование последнего испускаемого значения из наблюдаемого

Question

Во многих случаях мне нужно получить доступ к последнему испускаемому значению из наблюдаемого. То, как я это сделал, - это подписка на наблюдаемые и кеширующие значения по мере их появления. См. Ниже, например. Однако я вижу, что существует множество методов, таких как Observable.MostRecent, Observable.Latest, Replay (1) и т. Д., Которые, похоже, могут выполнить то, что я ищу, но я не могу понять, как их использовать. Есть ли лучший подход, чем метод, который я использую ниже?

public class WordPrinterWithCache 
{ 
    string _lastWord = string.Empty; 

    public WordPrinterWithCache(IObservable<string> words) 
    { 
     words.Subscribe(w => _lastWord = w); 
    } 

    public void PrintMostRecent() => Console.WriteLine(_lastWord); 
} 

Answer 1

Вот два метода, которые я бы рассмотрел при реализации этого поведения.

var bs = new BehaviorSubject<long>(0); //initial value 
source.Subscribe(bs.OnNext); 
Console.WriteLine(bs.Value); 

С BehaviorSubject вы можете получить доступ к последнему значению через свойство.

var ls = source.TakeLast(1); 
bs.Subscribe(Console.WriteLine); 

С TakeLast вы должны подписаться на доступ последнее значение (хотя только одно значение испускается перед утилизацией).