reactive-streams

3Hitze

2Antwort

Nachdem Reactive Streams Specification 1.0 veröffentlicht wurde, wird die jdbc-Spezifikation auch reaktiv werden?

Ich lernte und reaktive Streams mit Akka-Streams Programmierung, ich habe versucht, Bibliotheken für einen Async-JDBC-Treiber oder Reaktiv-JDBC-Treiber für 2 Jahre zu finden, und ich fand glatt 3.0 od

8Hitze

1Antwort

Wie kann ich ein materialisiertes Akka Stream Flussdiagramm veröffentlichen oder abonnieren?

Ich spiele mit Akka Stream und ich versuche, seine Flexibilität nach der Materialisierung herauszufinden. Eine Möglichkeit, dies zu tun, ist das niedrige Niveau reaktive Streams API zu verwenden: http

8Hitze

2Antwort

Wie verwende ich Reactive Streams für die NIO-Binärverarbeitung?

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

5Hitze

1Antwort

Was ist der Unterschied zwischen reaktiven und reaktiven Streams?

Ich versuche den Unterschied zwischen Reactive und ReactiveStreams zu verstehen, speziell im Kontext von RxJava? Das meiste, was ich herausfinden konnte, war, dass Reactive Streams eine gewisse Vorste

5Hitze

1Antwort

Erstellen einer Quelle aus einem EventStream

Ich benutze PlayFramework 2.5.3 und möchte eine akka.stream.scaladsl.Source von einem akka.event.EventStream erstellen (der Eventstream ist Teil eines Actor-Systems). Der Ereignis-Stream würde Ereigni

3Hitze

2Antwort

Akka Reactive Streams immer eine Nachricht hinter

Aus irgendeinem Grund warten meine Akka-Streams immer auf eine zweite Nachricht, bevor sie den ersten "ausstrahlen" (?). Hier ist ein Beispiel Code, der mein Problem zeigt. val rx = Source((1 to 100).

14Hitze

1Antwort

Fehler beim Erstellen des Diagramms: Anforderung fehlgeschlagen: Die Eingänge [] und Ausgänge [] müssen den Eingängen [in] und Ausgängen [out] entsprechen

Ich verwende akka streams graphDSL, um ein lauffähiges Diagramm zu erstellen. Es gibt keine Kompilierungszeitfehler beim Ein-/Ausgang der Stream-Komponenten. Runtime löst folgenden Fehler aus: Irgendw

7Hitze

1Antwort

Akka HTTP: Wie JSON-Format Antwort in Domain-Objekte zu entpacken

Ich versuche Akka HTTP, und ich habe einen Dienst erstellt, der ein JSON-Array von Domänenobjekten in HttpResponse zurückgibt. Im Client möchte ich es in eine Quelle von Domain-Objekten konvertieren,