Java Rx - 过滤定时事件

Question

假设我的observable发出整数。如果在最近30秒内x不是由observable生成的，我希望我的观察者可以使用整数x。

该行为类似于谴责，但倒置。

Answer 1

也许这不是更优雅和简洁的解决方案，但我认为你可以使用像一个过滤器下面

这个解决方案，因为不完美：由发射器触发，以达到预期效果，你必须发出TIME后假事件刷新去年

private static class TimedFilter<T> implements Func1<T, Collection<T>>{ 

    private NavigableMap<Long,T> treeMap = new TreeMap<>(); 
    private HashMap<T,Long> indexes = new HashMap<>(); 
    private final long delta_millis; 

    public TimedFilter(long delta_millis) { 
     this.delta_millis = delta_millis; 
    } 

    @Override 
    public Collection<T> call(T x) { 

     long now_millis = System.currentTimeMillis(); 

     Long oldIndex = indexes.put(x, now_millis); 

     if(oldIndex!=null) 
      treeMap.remove(oldIndex); // throws NPE - if the specified key is null and this map uses natural ordering 

     treeMap.put(now_millis,x); 

     long then_millis = now_millis - delta_millis; 
     Collection<T> values = treeMap.headMap(then_millis).values(); 
     for (T v : values){ 
      indexes.remove(v); 
     } 

     treeMap = treeMap.tailMap(then_millis, true); 
     return values; 
    } 
} 

测试

void testFunction(){ 
    getEmitter() 
      .map(new TimedFilter<>(TIME)) 
      .flatMap(Observable::from) 
      .subscribe(System.out::print) 
    ; 
} 

更新： as @tilois建议使用System.nanoTime()更可靠，如果你运行un Android，也可以使用返回millis的SystemClock.elapsedRealtime()。 ;