RX: Biến đổi trạng thái của chuỗi, ví dụ: trung bình di động theo cấp số nhân

Question

Bạn có thể làm như thế nào trong RX một biến đổi đơn giản, trạng thái của một chuỗi?

Giả sử chúng tôi muốn thực hiện chuyển đổi trung bình chuyển động theo hàm mũ của IObservable noisySequence.

Bất cứ khi nào noisySequence ve, emaSequence nên đánh dấu vào và trả về giá trị (previousEmaSequenceValue * (1-lambda) + latestNoisySequenceValue * lambda)

Tôi đoán chúng tôi sử dụng Đối tượng, nhưng làm thế nào chính xác?

public static void Main() 
    { 

     var rand = new Random(); 

     IObservable<double> sequence = Observable 
      .Interval(TimeSpan.FromMilliseconds(1000)) 
      .Select(value => value + rand.NextDouble()); 

     Func<double, double> addNoise = x => x + 10*(rand.NextDouble() - 0.5); 

     IObservable<double> noisySequence = sequence.Select(addNoise); 

     Subject<double> exponentialMovingAverage = new Subject<double>(); // ??? 


     sequence.Subscribe(value => Console.WriteLine("original sequence "+value)); 
     noisySequence.Subscribe(value => Console.WriteLine("noisy sequence " + value)); 
     exponentialMovingAverage.Subscribe(value => Console.WriteLine("ema sequence " + value)); 

     Console.ReadLine(); 
    } 

Answer 1

Đối với nhiều người của các loại tính toán, Buffer là cách dễ nhất

var movingAverage = noisySequence.Buffer(/*last*/ 3, /*move forward/* 1 /*at a time*/) 
    .Select(x => (x[0] + x[1] + x[2])/3.0); 

Nếu bạn cần để thực hiện nhà nước xung quanh, sử dụng Scan điều hành, mà là giống như Aggregate ngoại trừ việc nó mang lại giá trị mỗi lặp lại.

Answer 2

Đây là cách bạn có thể đính kèm trạng thái vào chuỗi. Trong trường hợp này, nó tính giá trị trung bình của 10 giá trị cuối cùng.

var movingAvg = noisySequence.Scan(new List<double>(), 
(buffer, value)=> 
{ 
    buffer.Add(value); 
    if(buffer.Count>MaxSize) 
    { 
     buffer.RemoveAt(0); 
    } 
    return buffer; 
}).Select(buffer=>buffer.Average()); 

Nhưng bạn có thể sử dụng Window (bộ đệm là loại tổng quát) để đạt được mức trung bình.

noisySequence.Window(10) 
    .Select(window=>window.Average()) 
    .SelectMany(averageSequence=>averageSequence); 

Answer 3

Cảm ơn! Đây là giải pháp sử dụng Quét

const double lambda = 0.99; 
    IObservable<double> emaSequence = noisySequence.Scan(Double.NaN, (emaValue, value) => 
     { 
      if (Double.IsNaN(emaValue)) 
      { 
       emaValue = value; 
      } 
      else 
      { 
       emaValue = emaValue*lambda + value*(1-lambda); 
      } 
      return emaValue; 
     }).Select(emaValue => emaValue);