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()。 ;