Rxを使用して各ウィンドウの取り消しを伴う遅延アクションを1回実行します。

Question

具体的には、しきい値（T）を超えるキーが押された場合に動作をシミュレートしようとしています。

私はReactive Extensions .NET（安定版1.0）を使用して状態変数を使用してこれを実行しようとしています。

は、ここに私の入力の大理石の図だと私は必要なもの：

は

KeyDownイベントを（ "押したままキー" を構成するキーアップイベントなしSO 4 DDDD）T = 3を聞かせて： - -dddd --- dd-d-dddddddddd -----

keyUp：----------- u ----- u - u -------- ------- u--

希望：-------- a --------------- a --------- -

これは私が思いついたコードの例ですが、状態変数を使います。

var keyDownStream = Observable.FromEventPattern<KeyEventArgs>(this, "KeyDown").Where(args => args.EventArgs.Key == Key.OemPeriod); 
     var keyUpStream = Observable.FromEventPattern<KeyEventArgs>(this, "KeyUp").Where(args => args.EventArgs.Key == Key.OemPeriod); 

     var repeatGuard = false; 
     keyUpStream.Subscribe(x => repeatGuard = false); 
     keyDownStream 
      .DelayOrCancel(TimeSpan.FromSeconds(2.0), keyUpStream) 
      .Where(_ => repeatGuard == false) 
      .Do(_ => 
      { 
       repeatGuard = true; 
      }) 
      .Subscribe(
       result => 
       { 
        Console.WriteLine("KeyHold"); 
       } 
      ); 

public static class JustinsRx 
{ 
    public static IObservable<T> DelayOrCancel<T, TCancel>(this IObservable<T> source, 
            TimeSpan delay, 
            IObservable<TCancel> cancel) 
    { 
     //argument checking skipped 
     return from s in source 
       from i in Observable.Timer(delay).TakeUntil(cancel) 
       select s; 
    } 
} 

Answer 1

これは動作しますが、私はそれを短くすることができることを感じます。

var firstKeyDowns = Observable 
    .Merge(keyDownStream.Select(_ => 'd'), keyUpStream.Select(_ => 'u')) 
    .DistinctUntilChanged() 
    .Where(c => c == 'd'); 
var query = from s in firstKeyDowns 
      from i in Observable.Timer(delay).TakeUntil(keyUpStream) 
      select s; 

編集：ここで私は少しよりよいと思い異なるバージョンです：

var noRepeats = Observable 
    .Merge(keyDownStream.Select(_ => 'd'), keyUpStream.Select(_ => 'u')) 
    .DistinctUntilChanged(); 
var query = noRepeats 
    .Throttle(delay) 
    .Where(c => c == 'd'); 

Answer 2

これが私の仕事：

var timer = Observable.Timer(TimeSpan.FromSeconds(1.0)); 

var query = 
    keyDownStream 
     .Select(_ => 
      keyUpStream 
       .Select(_ => 'u') 
       .Amb(timer.Select(_ => 't')) 
       .Take(1) 
       .Where(x => x == 'u') 
       .Select(_ => Unit.Default)) 
     .Switch();