强制刷新到 Observable.Buffer c#

有没有办法强制 Observable.Buffer 在缓冲时间结束之前刷新？

在示例中：

mSubscription = mFluxObservable.Buffer(new TimeSpan(0, 0, 1, 30)).Subscribe(o => saver(o, iSessionId));

我想在 1:30 时段结束之前刷新数据！

这对我有用：

var subject = new Subject<Unit>();
var closing = Observable
    .Timer(new TimeSpan(0, 0, 1, 30))
    .Select(x => Unit.Default);

var query =
    mFluxObservable
        .Buffer(() => Observable
            .Amb(subject, closing)
            .Take(1));

现在我只需要打电话subject.OnNext(Unit.Default)强制刷新缓冲区。刷新后立即启动新的缓冲区。