RxJava - sehr lange Verzögerung

Question

Ich muss Verzögerungsoperator von RxJava verwenden. Kann mir jemand erklären, wie es funktioniert? Schläft der Thread während der Verzögerung? Wie genau ist die Verzögerung? Ich muss im schlimmsten Fall fast 1 Tag (24 Stunden Verspätung) ausgeben.

Answer 1

Mit dem Verzögerungsoperator verzögern wir die Erstellung der Pipeline von faul zu eifrig. Aber einmal starten Sie den Verzögerungsoperator emittiert die Elemente nicht beeinträchtigt emittiert

@Test 
public void delayCreation() { 
    long start = System.currentTimeMillis(); 
    Subscription subscription = Observable.just("hello reactive world") 
      .delay(200, TimeUnit.MICROSECONDS) 
      .subscribe(n -> System.out.println("time:" + (System.currentTimeMillis() - start))); 
    new TestSubscriber((Observer) subscription).awaitTerminalEvent(1000, TimeUnit.MILLISECONDS); 
} 

Sie können weitere Beispiele für Verzögerung sehen hier https://github.com/politrons/reactive/blob/master/src/test/java/rx/observables/utils/ObservableDelay.java