Lazy Zufallsgenerator als beobachtbar

Question

Ich muss Zufallsgenerator als beobachtbar schreiben. Beobachter wird etwas mit dem nächsten Wert eine lange Zeit machen. Ich möchte also nur dann eine neue Zufallszahl ausgeben, wenn der Beobachter es möchte oder zwei zusätzliche Zahlen, aber nicht mehr.

Wie geht das?

P.S. Wenn es darauf ankommt, verwende ich Java.

Answer 1

Sie könnten fromCallable mit repeat verwenden, um einen neuen Wert immer dann zu erhalten, wenn eine Nachfrage seitens des Verbrauchers besteht.

Zum Beispiel:

Random random = new Random(); 
Observable.fromCallable(() -> random.nextDouble()) 
.repeat() 
.map(rnd -> { 
    // do something with the random number 
    return rnd * 2; 
} 
.take(50) 
.subscribe(System.out::println); 

Answer 2

Verwenden Sie die wenig bekannte SyncOnSubscribe:

Observable 
.create(SyncOnSubscribe.createStateless(observer -> observer.onNext(random.nextDouble)) 
.map(...) 
.take(...) 
.subscribe(...) 

Dies wird mit Rückstau korrekt funktionieren.