Sequence-Erkennung mit reaktiven Rahmen

Question

Ich bin ein Neuling von Rx Framework und ich hätte gerne eine Hilfe bei der Herstellung einer Konsolenanwendung, die die Eingabe-Sequenz der Zeichenfolge von "A" und "B" mit reaktiven Rahmen erkennen.

Hier ist mein Code, der die ursprüngliche Eingabesequenz (Quelle) und die abgeleitete Sequenz zeigt. Die Sequenz "A" und "B" wird korrekt erkannt, aber ich möchte sie nicht erkennen, wenn ich eine andere Zeichenfolge zwischen "A" und "B" erhalte:

für zB "A" "C" "B" ist keine gültige Sequenz

Vielen Dank.

static void Main(string[] args) 
     { 
      var subj = new Subject<string>(); 
      var source = subj.AsObservable(); 
      source.Subscribe(Console.WriteLine); 
      var derived = from first in source.Where(x => x == "A") 
          from second in source.Where(x => x == "B") 
          select new[] { first, second }; 
      derived.Subscribe(x => Console.WriteLine("Derived: " + x[0] + " " +x[1])); 

      subj.OnNext("A"); 
      subj.OnNext("B"); 
      subj.OnNext("C"); 
      subj.OnNext("D"); 
      subj.OnNext("E"); 
      subj.OnNext("F"); 

      Console.ReadLine(); 
     } 

Answer 1

Versuchen Sie derived Abfrage dieser Wechsel:

var derived = 
    source 
     .Publish(ss => ss.Zip(ss.Skip(1), (a, b) => new [] { a, b })) 
     .Where(xs => xs.SequenceEqual(new [] { "A", "B" })); 

Oder:

var derived = 
    source 
     .Buffer(2, 1) 
     .Where(xs => xs.SequenceEqual(new [] { "A", "B" }));