RX - 被験者が基準を満たしている場合にのみコードを実行する

Question

私はobservablesを使用してkeydownイベントを処理しています。 消費者が実際に処理した場合は、常に扱いの鍵を設定するオブザーバブルを公開したいと思います。 これは可能ですか？ここで

は、私が今扱っキーを設定する方法の例です：

KeyDown.Where(e => e.Key == Keys.W) 
.Subscribe(e => { Console.WriteLine(e.Key); e.Handled = true; }); 

ここで扱わプロパティは自動的にその後設定された場合、私はちょうどキーの代わりKeyDownEventArgsを公開することができ（私はそれを行うしたいと思います方法の例ですあまりにも）：

HandledKeyDown.Where(k => k == Keys.W).Subscribe(k => Console.WriteLine(k)); 

ここに私が試したものです：

HandledKeyDown = Observable.Create<Key>(observer => { 
    var keys = KeyDown.Subscribe(e => { e.Handled = true; observer.OnNext(e.Key); }); 
    return() => keys.Dispose(); 
}); 

T消費者が実際に処理したかどうかにかかわらず、キーは常に処理されるように設定されるということです。

コードがサブスクライブ方式に「到達」しているかどうかを知る方法はありますか？

Answer 1

は、サブスクリプションの後に処理として、イベントを作るようにKeyEventArgsにサブスクリプションをオーバーロードすることです。延長のような音：

public static IDisposable SubscribeAndHandle(this IObservable<KeyEventArgs> input, Action<Keys> action) 
{ 
    return input.Subscribe(e => { action(e.KeyCode); e.Handled = true; }); 
} 

は次に、あなただけの代わりにSubscribeのSubscribeAndHandleを使用し、アクションが実行された後にのみtrueにHandledを設定し、アクションを使用することができますKeysないKeyEventArgs：

var sub = KeyDown 
      .Where(e => e.KeyCode = Keys.W) // and so on 
      .SubscribeAndHandle(k => Console.WriteLine(k)); 

---

アクションが実行される前にHandledがtrueに設定されていても構わない場合は、拡張メソッドではなくDoを使用できます。 @Enigmativityから有用なコメントは、おそらくあなたがHandledは、サブスクリプション内からtrueまたはしないように設定されているかどうかを決定したいかもしれないことを示唆し

public static IDisposable SubscribeAndHandle(this IObservable<KeyEventArgs> input, Action<Keys> action) 
{ 
    return input.Do(e => e.Handled = true) 
       .Select(e => e.KeyCode) 
       .Subscribe(e => action(e)); 
} 

---

：これは副作用を実行するクリーンな方法です。これは十分に簡単です、ただFunc<Keys,bool>はなくAction<Keys>受け入れるように拡張メソッドを変更：答えのための

public static IDisposable SubscribeAndHandle(this IObservable<KeyEventArgs> input, Func<Keys,bool> action) 
{ 
    return input.Subscribe(e => e.Handled = action(e.KeyCode)); 
} 

Answer 2

私はこのような何かをやって見ます：

var HandledKeyDown = 
    KeyDown 
     .Do(e => { /* Handling Code Here */ }) 
     .Where(e => e.Handled) 
     .Where(e => e.Key == Keys.W) 
     .Select(e => e.Key) 
     .Subscribe(k => Console.WriteLine(k)); 

Do拡張メソッドを使う「インターセプト」観測可能なインラインの値ができます。

これが役立つかどうか教えてください。あなたが好きな何