Mit einem Flux anstelle einer For-Schleife, irgendwelche Vorteile?

Question

Ich versuche, meinen Kopf um reaktive Programmierung zu bekommen, damit ich es möchte fragen, ob jeder Vorteil hier mit einem Flux ist:

override fun notifyObserversOnMessage(message: Message) { 
     Flux.fromStream(observers.stream()) 
       .map { observer -> Mono.just(observer.reactOnMessage(message)) } 
       .subscribe()   
    } 

statt:

override fun notifyObserversOnMessage(message: Message) { 
     for (observer in observers) { 
      observer.reactOnMessage(message) 
     }  
    } 

es auf Hängt die Arbeit, die jeder Beobachter macht und ob das IO ist oder nicht?

Answer 1

Kommt drauf an.

Wenn es sinnvoll ist observers sequentiell zu verarbeiten, gibt es keinen Vorteil durch die Verwendung hier Flux und

override fun notifyObserversOnMessage(message: Message) { 
    observers.forEach { observer -> 
     observer.reactOnMessage(message) 
    } 
} 

oder einfach

override fun notifyObserversOnMessage(message: Message) { 
    observers.forEach { it.reactOnMessage(message) } 
} 

ist in Ordnung.

Für naive Parallelität,

override fun notifyObserversOnMessage(message: Message) { 
    observers.parallelStream().forEach { it.reactOnMessage(message) } 
} 

verwendet werden kann, aber an diesem Punkt ist es eher wahrscheinlich, dass Sie zusätzliche Anforderungen wie Arbeiter-Pools oder Timeouts. In diesem Fall ist die Aussagekraft des Reaktors nützlich.