반응성 프레임 워크/더블

Question

내가 이렇게 쉬운 방법이 있다는 것을 알고있다 -하지만 나에게 오늘 밤을 이겼습니다 ... 나는 두 개의 이벤트가 같이 서로 300 밀리 초 이내에 발생하는 경우 알고 싶어

더블 클릭.

왼쪽 두 번의 마우스 클릭 300 밀리 초 - 반응 형 프레임 워크가 무엇인지 알아 냈습니다. 그러나 모든 확장 작업에 대한 간단한 예제가있는 좋은 문서를 찾을 수 있다면 망할 것입니다. - Throttle, BufferWithCount, BufferWithTime - all 그 중 단지 나를 위해 그것을하고있는 werent '...

Answer 1

TimeInterval 방법은 당신에게 값 사이의 시간을 줄 것이다 : 당신은 당신이 받고있어 정확히 알 수 있도록

var ioClicks = Observable.FromEvent<MouseButtonEventHandler, RoutedEventArgs>(
             h => new MouseButtonEventHandler(h), 
             h => btn.MouseLeftButtonDown += h, 
             h => btn.MouseLeftButtonDown -= h); 
var ioTSClicks = ioClicks.Timestamp(); 

var iodblClicks = ioTSClicks.Zip(ioTSClicks.Skip(1), 
           (r, l) => l.Timestamp - r.Timestamp) 
          .Where(tspan => tspan.TotalMilliseconds < 300); 

은 아마 최고의 테스트 스케줄러를 통해이 문제를 테스트합니다. 그냥 뜨거운 관찰에 Repeat를 사용할 수 있습니다 당신은 트리플 클릭 값을 트리거하지 않습니다 있는지 확인하려면

public static IObservable<Unit> DoubleClicks<TSource>(
    this IObservable<TSource> source, TimeSpan doubleClickSpeed, IScheduler scheduler) 
{ 
    return source 
     .TimeInterval(scheduler) 
     .Skip(1) 
     .Where(interval => interval.Interval <= doubleClickSpeed) 
     .RemoveTimeInterval(); 
} 

, (나는 모든 하나 개의 스레드 따라서에 올 것이다 클릭으로 여기 FastSubject을 사용했습니다 뿐만 아니라

public static IObservable<TSource> DoubleClicks<TSource>(
    this IObservable<TSource> source, TimeSpan doubleClickSpeed, IScheduler scheduler) 
{ 
    return source.Multicast<TSource, TSource, TSource>(
     () => new FastSubject<TSource>(), // events won't be multithreaded 
     values => 
     { 
      return values 
       .TimeInterval(scheduler) 
       .Skip(1) 
       .Where(interval => interval.Interval <= doubleClickSpeed) 
       .RemoveTimeInterval() 
       .Take(1) 
       .Repeat(); 
     }); 
} 

Answer 2

편집 - TimeInterval()를 대신 사용하십시오.

Zip() and Timestamp() 연산자가 좋은 시작일 수 있습니다.

[Fact] 
public void DblClick() 
{ 
    // setup 
    var ioClicks = _scheduler.CreateHotObservable(
        OnNext(210, "click"), 
        OnNext(220, "click"), 
        OnNext(300, "click"), 
        OnNext(365, "click")) 
        .Timestamp(_scheduler); 

    // act 
    Func<IObservable<TimeSpan>> target = 
     () => ioClicks.Zip(ioClicks.Skip(1), 
          (r, l) => l.Timestamp - r.Timestamp) 
         .Where(tspan => tspan.Ticks < 30); 
    var actuals = _scheduler.Run(target); 

    // assert 
    Assert.Equal(actuals.Count(), 1); 
    // + more 
} 
public static Recorded<Notification<T>> OnNext<T>(long ticks, T value) 
{ 
    return new Recorded<Notification<T>>(
     ticks, 
     new Notification<T>.OnNext(value)); 
}