c# - 将最后一项推送到 Observable(序列)

Question

我有一个 IObservable<Item>在一个类中，我想公开一个只读属性，该属性提供在给定时间推送到可观察对象的最后一项。所以它将提供一个单一的值 Item .

如果没有值被推送，那么它必须返回一个默认值。

我怎样才能做到这一点而不必订阅 observable 并且没有“支持字段”？

Answer 1

只是在这里补充一下@Asti 的回答，也许可以帮助您解决挫败感:

Observable 不是物理“事物”，它更像是一个逻辑概念。经常将 Rx 与 LINQ 进行比较，并且在很多时候这是一个公平的比较。但当您开始谈论数据结构时，它会崩溃:LINQ 的枚举与用于学习目的的列表非常相似。

但是，在 Rx 方面，根本没有与 List 等效的东西。可观察对象是一种 transient 数据结构，所有运算符都处理这种 transient 。如果您正在寻找永久状态，那么您将离开 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);