Wie Hot-Stream in Reactive Programming

Question

Gemäß dem Reaktiv-Stream-Paradigma,

Zeit zu implementieren, haben wir auf dem kalten Strom in erster Linie konzentriert. Dies sind statische Ströme fester Länge, die leicht zu handhaben sind. Ein realistischerer Anwendungsfall für reaktive könnte etwas sein, das unendlich geschieht. Zum Beispiel könnten wir einen Strom von Mausbewegungen haben, auf die ständig reagiert werden muss, oder einen Twitter-Feed. Diese Arten von Streams werden als heiße Streams bezeichnet, da sie immer ausgeführt werden und zu jedem Zeitpunkt abonniert werden können, wobei der Beginn der Daten fehlt.

Also, wie können wir diesen heißen Strom implementieren?

Answer 1

Das die ConnectableFlux getan werden kann, wie folgt verwendet:

ConnectableFlux<Object> publish = Flux.create(fluxSink -> { 
    while(true) { 
     fluxSink.next(System.currentTimeMillis()); 
    } 
}) 
    .publish();