RxJava debounced मर्ज और नहीं debounced observables

Question

मैं दो observables है:

नमूदार हे (खुला): TextView में खोला कुछ सामग्री के साथ फ़ाइल

प्रत्यक्ष ई (संपादित): फ़ाइल सामग्री TextView में संपादित

मैं ई देखने योग्य को अस्वीकार करना चाहता हूं, और इसे ओ देखने योग्य के साथ विलय करना चाहता हूं।

:

new content: O1 
new content: E1 // this output is rebundant (cuz we already have newer content O1) 

यह क्या चल रहा है का एक चित्र है:

obs = Observable.merge(E.debounce(2000, TimeUnit.MILLISECONDS) , O) 
       .subscribe(content->System.out.println("new content: " + content)) 

समस्या

कि अगर ई एक घटना E1 का उत्सर्जन करता है और सही है कि हे के बाद O1 घटना का उत्सर्जन करता है, हम उत्पादन किया है

इस अत्यधिक पुरानी घटना से छुटकारा पाने के लिए कैसे देखा जा सकता है?

Answer 1

आप

Observable.merge(O, O.switchMap(o -> E.debounce())) 
      .subscribe() 

switchMap बर्ताव बहुत तरह flatMap, जब भी कोई नया आइटम स्रोत प्रत्यक्ष द्वारा उत्सर्जित होता है सिवाय इसके कि, यह करने के लिए सदस्यता समाप्त करने और प्रत्यक्ष मिरर बंद हो जाएगा कोशिश कर सकते हैं जिसे से पहले से उत्सर्जित आइटम से उत्पन्न किया गया था, और केवल वर्तमान को मिरर करना शुरू कर देता है।

Answer 2

मैं दो मुख्य विकल्प देखें। एक टाइमस्टैम्प का उपयोग करना है जो काफी आसान है लेकिन सैद्धांतिक दौड़ की स्थिति (लेकिन अनुमानित बहुत संभावना नहीं है) और दूसरा विकल्प प्रत्येक फ़ाइल खोलने से जुड़े एक अद्वितीय पहचानकर्ता का उपयोग करना है और उस खुली फ़ाइल के पाठ में संपादन से उत्सर्जित घटनाएं हैं फ़ाइल खोलने के पहचानकर्ता के साथ।

का उपयोग timestamps:

obs = Observable.defer(() -> { 
    AtomicBoolean first = new AtomicBoolean(true); 
    e.timestamp() 
    .debounce(2000, TimeUnit.MILLISECONDS)) 
    .mergeWith(o.timestamp()) 
    .buffer(2,1) 
    .flatMap(list -> { 
    Observable<Object> start; 
    if (first.compareAndSet(true, false)) 
     start = Observable.just(list.get(0).getValue()); 
    else 
     start = Observable.empty(); 
    if (list.size() == 1) 
     return start; 
    else { 
     Timestamped<Object> a = list.get(0); 
     Timestamped<Object> b = list.get(1); 
     if (a.getTimestampMillis() <= b.getTimestampMillis()) 
     return start.concatWith(Observable.just(b.getValue())); 
     else 
     return start; 
    } 
    }) 
}); 

मुझे लगता है टाइमस्टैंप संस्करण पर्याप्त होगा।