.net - 是否有一个 react 性框架主题可以缓冲直到不需要？

Question

调整第 3 方库以公开时 IObservable ，有时不可避免地必须使用 ReplaySubject 之类的东西。在您意识到流可用之后，在您可以让某人订阅它之前，在短时间内缓冲结果。

一个 ReplaySubject在短时间内“通常”会工作，但并非总是如此，然后是浪费，维护一个滚动队列，一旦订阅者正在收听可能就不需要了。

是否有建议的“主题在有人听之前缓冲？”的模式？

Answer 1

我不确定我是否正确理解了这个问题。但是根据你最后一句话subject which buffers until someone is listening ，您可以执行以下扩展方法

static IObservable<T> BufferUntillSubscribe<T>(this IObservable<T> obs)
{
    var replay = new ReplaySubject<T>();
    var disposable = obs.Subscribe(replay);
    return Observable.CreateWithDisposable<T>((subscriber) =>
    {
        disposable.Dispose();
        return replay.Merge(obs).Subscribe(subscriber);
    });
}