c# - 动态延迟 IObservable 值的延迟函数

Question

[这个问题是关于IObservable / Rx ]

工作固定延迟

var frequency = TimeSpan.FromMinutes(5);
Result.Delay(frequency).Subscribe(i => Debug.WriteLine("After Fixed Delay"));

可变延迟的伪代码

Result.Delay(GetAsymptotingTime()).Subscribe(i => Debug.WriteLine("After Changing Delay"));

虽然变量延迟的代码编译它只被调用一次，只提供第一个值（本质上是一个固定值）。

• 你怎么能订阅响应式扩展的动态延迟？

Answer 1

看起来有一个新的 .Delay 重载允许在 RX 本身内实现此功能：

来自http://blogs.msdn.com/b/rxteam/archive/2012/03/12/reactive-extensions-v2-0-beta-available-now.aspx：

var res = input.Delay(x => Observable.Timer(TimeSpan.FromSeconds(x.Length)));

给定用户输入，它的延迟时间等于输入长度（以秒为单位）。换句话说，每个元素的延迟现在可以取决于数据本身。

Answer 2

我认为这有效：

source
  .SelectMany(i => Observable.Timer(GetAsymptotingTime()).Select(_=>i))

如果您的延迟正在减少，则生成的流可能与原始流的顺序不同。

Answer 3

可能是我没有得到正确的问题，但是当我正在寻找一种在项目之间放置相同固定延迟的方法时，我已经介入了它，这太快了。以前的解决方案对我不起作用，（RX 4.0）实际上根本没有延迟。

我的解决方案很简单：

myObservable.Zip(Observable.Interval(TimeSpan.FromSeconds(1)), (a, _) => a)

我在测试动态序列时使用过它

      using var d2 = new int[] { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17 }
        .ToObservable()
        .Zip(Observable.Interval(TimeSpan.FromSeconds(1)), (a, _) => a)
        .Do(a => Log.Logger.Debug("b {a}", a))
        .Subscribe();

Answer 4

如果你想延迟一次，那么你可以使用 Observable.Delay。我不知道 Result 的类型是什么，所以我假设它已经是一个 IObservable ，所以，你可以这样做：

    var Result = Observable.Range(0, 10);
var frequency = TimeSpan.FromMilliseconds(1500);
var delay = Result.Delay(frequency);
delay.Subscribe(x => Debug.WriteLine(x));