如何在Rx中交替缓冲和流动实时数据流
我有两个流。 一个是数据流(可以是任何类型),另一个是作为门的布尔流。 我需要将这些组合成一个具有以下行为的流:
我真的不确定如何把它放在一起。 我一直在测试的输入是这样的:
// a demo data stream that emits every second var dataStream = Observable.Interval(TimeSpan.FromSeconds(1)); // a demo flag stream that toggles every 5 seconds var toggle = false; var gateStream = Observable.Interval(TimeSpan.FromSeconds(5)) .Select(_ => toggle = !toggle);
我会这样做如下:
它看起来像这样:
上述就是C#学习教程:如何在Rx中交替缓冲和流动实时数据流分享的全部内容,如果对大家有所用处且需要了解更多关于C#学习教程,希望大家多多关注—计算机技术网(www.ctvol.com)!
dataStream.Window(gateStream.StartWith(false).DistinctUntilChanged()) .Select((w, i) => i % 2 == 0 ? w.ToList().SelectMany(x => x) : w) .Concat() .Subscribe(Console.WriteLine);
本文来自网络收集,不代表计算机技术网立场,如涉及侵权请联系管理员删除。
ctvol管理联系方式QQ:251552304
本文章地址:https://www.ctvol.com/cdevelopment/1020738.html