reactive-streams

In Akka streamt, was Mat in Quelle [Out, Mat] oder Sink [In, Mat] repräsentiert. Wann wird es tatsächlich benutzt?     

Wie konvertiert man Observable in RxJava Version 2 in Publisher? In der ersten Version haben wir das Projekt Ссылка , das genau das tut, was ich brauche. Aber wie kann ich es in RxJava 2 machen?     

Gibt es einige Codebeispiele für die Verwendung von Bibliotheken org.reactivestreams zur Verarbeitung großer Datenströme mit Java NIO (für hohe Leistung)? ? Ich strebe eine verteilte Verarbeitung an, also wären Beispiele, die Akka verwenden, a...

Ich spiele mit Akka Stream und ich versuche seine Flexibilität nach der Materialisierung herauszufinden. Eine Möglichkeit, dies zu tun, ist die Verwendung der API für reaktive Datenströme mit niedriger Stufe: Ссылка Sie müssen diese Punk...

Ich bin dabei, eine selbst erstellte Bibliothek für die Protokollverarbeitung zu ersetzen, die ReactiveStreams mit io.projectreactor sehr nahe kommt. Das Ziel besteht darin, den von uns gepflegten Code zu reduzieren und neue Funktionen zu nut...