c# – 带有被动扩展的分区序列

var source = new[] { 'a','b',';','c','d','e',';' }.ToObservable();

这是你要求的：

var groups = source
    // Group the elements by some constant (0)
    // and end the group when we see a semicolon
    .GroupByUntil(x => 0,group => group.Where(x => x == ';'))

这是一种使用它的方法：

groups
    // Log that we're on the next group Now.
    .Do(x => Console.WriteLine("Group: "))
    // Merge / Concat all the groups together
    // {{a..b..;}..{C..d..e..;}} => {a..b..;..c..d..e..;}
    .Merge()
    // Ignore the semicolons? This is optional,I suppose.
    .Where(x => x != ';')
    // Log the characters!
    .Do(x => Console.WriteLine("  {0}",X))
    // Make it so,number One!
    .Subscribe();

输出：

Group:
  a
  b
Group:
  c
  d
  e