0

私はジョセフ・アルバハリからオブザーバブルを取っています：

IObservable<int> GetHeartBeat()
{
    return Observable.Create<int>((observer, cancelToken) => this.Start(observer, cancelToken));
}

async Task Start(IObserver<int> observer, CancellationToken cancelToken)
{
    int beat = 0;
    var random = new Random();
    while (beat < 10)
    {
        await Task.Delay(random.Next(500) + 700, cancelToken);
        observer.OnNext(beat);
        beat++;
    }
}

そして、私はこれを実行します:

var observable = this.GetHeartBeat()
    .TimeInterval()
    .Buffer(3, 1)
    .Select(l => l.Average(x => 60 / x.Interval.TotalSeconds));
observable
    .Select(i => string.Format("{0}, ", i))
    .Concat(observable.Count().Select(i => string.Format("{0}", i)))
    .Subscribe(i => System.Diagnostics.Debug.WriteLine(i));
observable.Wait();

私はこれを見ることを期待しています：

71.9889864709428, 1
72.9592264002639, 2
67.6743699542054, 3

等

しかし、私はこれを見ています：

71.9889864709428, 
72.9592264002639, 
67.6743699542054,

私は今、どれほど深く間違っていることができますか?

4

2 に答える 2

1

これが必要だと思います：

var observable = this.GetHeartBeat()
    .TimeInterval()
    .Buffer(3, 1)
    .Select((l, i) => string.Format("{0}, {1}", l.Average(x => 60 / x.Interval.TotalSeconds), i))
    .Subscribe(i => System.Diagnostics.Debug.WriteLine(i));
于 2013-11-07T23:54:17.793 に答える