C＃のobservablesを分割する

Question

私は、観察可能なシーケンスを別々のシーケンスに分割して、与えられた述語に基づいて独立して処理できる方法を探しています。私が思い付くことができました最も近い2つのwhereのフィルタをやっている

var (evens, odds) = observable.Partition(x => x % 2 == 0); 
var strings = evens.Select(x => x.ToString()); 
var floats = odds.Select(x => x/2.0); 

が、それは、私は野生ではないよこれ、状態を評価し、二回ソースシーケンスを処理する必要があります。このような何かが理想的です約。

observable = observable.Publish().RefCount(); 
var strings = observable.Where(x => x % 2 == 0).Select(x => x.ToString()); 
var floats = observable.Where(x => x % 2 != 0).Select(x => x/2.0); 

F＃がObservable.partition<'T>とObservable.split<'T,'U1,'U2>で、このための良いサポートを持っているようだが、私は、C＃のための同等の何かを見つけることができていませんでした。

Answer 1

どう

var (odds,evens) = (collection.Where(a=> a % 2 == 1), collection.Where(a=> a % 2 == 0));? 

のようなものについてまたはあなたが一つの条件私はあなたが二度この方法の項目を反復処理しているという事実を中心に作業がないと思います

Func<int,bool> predicate = a => a%2==0; 

var (odds,evens) = (collection.Where(a=> !predicate(a)), collection.Where(a=> predicate(a))); 

に基づいてパーティションを作成する場合は、述語を受け取り、2つのsepatateコレクションを渡し、foreachまたはforの1回の反復でそれらを移入するメソッドを持つことが他に可能です。このような

何か：

var collection = new[] { 1, 2, 3, 4, 5, 6, 7, 8, 9}; 

Func<int,bool> predicate = a => a%2==0; 
var odds = new List<int>(); 
var evens = new List<int>(); 

Action<List<int>, List<int>, Func<int, bool>> partition = (collection1, collection2, pred) => 
{ 
    foreach (int element in collection) 
    { 
     if (pred(element)) 
     { 
      collection1.Add(element); 
     } 
     else 
     { 
      collection2.Add(element); 
     } 
    } 
}; 

partition(evens, odds, predicate); 

最後のアイデアを拡張し、あなたはこのような何かを探していますか？

public static (ObservableCollection<T>, ObservableCollection<T>) Partition<T>(this ObservableCollection<T> collection, Func<T, bool> predicate) 
{ 
    var collection1 = new ObservableCollection<T>(); 
    var collection2 = new ObservableCollection<T>(); 

    foreach (T element in collection) 
    { 
     if (predicate(element)) 
     { 
      collection1.Add(element); 
     } 
     else 
     { 
      collection2.Add(element); 
     } 
    } 

    return (collection1, collection2); 
} 

Answer 2

GroupByあなたはまだWhere句になってしまいますが、「二回観察」制限を削除することがあります。

public static class X 
{ 
    public static (IObservable<T> trues, IObservable<T> falsies) Partition<T>(this IObservable<T> source, Func<T, bool> partitioner) 
    { 
     var x = source.GroupBy(partitioner).Publish().RefCount(); 
     var trues = x.Where(g => g.Key == true).Merge(); 
     var falsies = x.Where(g => g.Key == false).Merge(); 
     return (trues, falsies); 
    } 
}