akka-stream

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,

5Hitze

1Antwort

Wie können mehrere Actors als Quellen an einen Akka-Stream angehängt werden?

Ich versuche, einen akka Stream Flow (in Java DSL) mit 2 Akteuren als Quellen, dann einer Merge-Kreuzung und dann 1 Waschbecken zu erstellen und auszuführen: Source<Integer, ActorRef> src1 = Source.ac

5Hitze

1Antwort

Wie gruppiert Teilströme mit mapAsync in akka verbrauchen Ströme

ich etwas wirklich ähnlich wie diese https://github.com/typesafehub/activator-akka-stream-scala/blob/master/src/main/scala/sample/stream/GroupLogFile.scala mein Problem tun müssen, ist, dass ich eine

10Hitze

1Antwort

Was ist der richtige Weg, um mit den Streaming-Ergebnissen von slick 3.0.0 und Postgresql zu arbeiten?

Ich versuche herauszufinden, wie man mit Slick-Streaming arbeitet. Ich benutze Slick 3.0.0 mit Postgres-Treiber Die Situation ist folgende: Server müssen Client-Sequenzen von Daten in Blöcken aufgetei

5Hitze

1Antwort

Gibt es eine Möglichkeit, mit Akka-Stream vorhersagbare Benennernamen zu bekommen?

Ich benutze eine ActorPublisher als Akka-Stream Source. Ich kann nicht herausfinden, wie man den Input-Akteur vorhersagbar nennt, damit ich ihm Nachrichten von anderen Teilen meiner Anwendung senden k

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

Get ganze HttpResponse Körper als String mit Akka-Streams HTTP

Ich versuche zu verstehen, wie die neue akka.http-Bibliothek zu verwenden. Ich möchte eine HTTP-Anfrage an einen Server senden und den gesamten Antworttext als eine einzelne Zeichenfolge lesen, um ein

7Hitze

1Antwort

Akka-http-Streaming-Slick 3.0 mit Databasepublisher

ich glatt 3.0 bin mit und haben eine databasepublisher Objekt als def getAsStream = db.stream[Entity](tblquery.result) ich akka-http für Restschicht verwende wie folgt val route = path("stream"){

26Hitze

3Antwort

Zugriff auf den zugrunde liegenden ActorRef eines akka stream Quelle erstellt von Source.actorRef

Ich versuche, die Source.actorRef Methode zu verwenden, um ein akka.stream.scaladsl.Source Objekt zu erstellen. Etwas von der Form import akka.stream.OverflowStrategy.fail import akka.stream.scaladsl

5Hitze

2Antwort

Wie reagiert man mit dem Ergebnis eines Schauspieleranrufs?

Wir schauen uns die Verwendung von Akka-HTTP Java API an - mit Routing DSL. Es ist nicht klar, wie die Routing-Funktionalität verwendet wird, um auf eine HttpRequest reagieren; einen Untyped Akka Acto