आरएक्स: अनुक्रम का राज्यगत परिवर्तन, उदा। घातीय चलती औसत

Question

आरएक्स में आप अनुक्रम के एक सरल, राज्यव्यापी परिवर्तन कैसे कर सकते हैं?

कहें कि हम एक IObservable शोर की आवश्यकता का एक घातीय चलती औसत परिवर्तन करना चाहते हैं।

जब भी noisySequence टिक्स, emaSequence टिकटिक और वापसी मूल्य (previousEmaSequenceValue * (1-लैम्ब्डा) + latestNoisySequenceValue * लैम्ब्डा)

मुझे लगता है कि हम विषय का उपयोग करें, लेकिन कैसे वास्तव में होना चाहिए?

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

गणना के इन प्रकार के कई के लिए, Buffer सबसे आसान तरीका है

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

आप के चारों ओर ले जाने के लिए राज्य, Scan ऑपरेटर, जो सिवाय यह मान हर पैदावार कि Aggregate की तरह है का उपयोग की जरूरत है है यात्रा।

Answer 2

इस प्रकार आप एक अनुक्रम में राज्य को जोड़ सकते हैं। इस मामले में यह पिछले 10 मानों के औसत की गणना करता है।

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()); 

लेकिन आप अपना औसत प्राप्त करने के लिए विंडो (जो बफर एक सामान्यीकरण का प्रकार है) का उपयोग कर सकते हैं।

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

Answer 3

धन्यवाद! स्कैन

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);