akka-stream

8Ciepło

2Odpowiedz

Jak dostarczyć domyślną wartość dla akka.stream.Materializer podczas wysyłania FakeRequest?

Próbuję zrozumieć błędy, które widzę poniżej, i dowiedzieć się, jak to naprawić. could not find implicit value for parameter materializer: akka.Stream.Materializer val fut: Future[Result] = actio

12Ciepło

1Odpowiedz

Strumienie Akka. Stan stanowy w przepływie

Chcę czytać wiele dużych plików, używając strumieni akka do przetwarzania każdej linii. Wyobraź sobie, że każdy klucz składa się z ("identyfikator" -> "wartość"). Jeśli zostanie znaleziony nowy "ident

5Ciepło

1Odpowiedz

Jak wysłać wiadomość w strumieniu reaktywnym z subskrybenta do wydawcy w połączeniu z gniazdem sieciowym

Moja aplikacja ma interfejs Akka-Websocket. W skład gniazda internetowego wchodzi aktor-subskrybent i wydawca aktorski. Abonent obsługuje polecenia, wysyłając je do odpowiedniego aktora. Wydawca słuch

10Ciepło

1Odpowiedz

Via/ViaMat/to/toMat w Akka Stream

Czy ktoś może wyjaśnić wyraźnie, jaka jest różnica między tymi 4 metodami? Kiedy lepiej użyć każdego z nich? Również ogólnie mówiąc, jaka jest nazwa tej grupy metod? Czy istnieje więcej metod, które w

8Ciepło

1Odpowiedz

Jak zmontować zlew w strumieniach Akka z wielu zapisów?

Próbuję zintegrować przepływ strumieniowy z akka w mojej aplikacji Play 2.5. Pomysł polega na tym, że można przesyłać strumieniowo na zdjęciu, a następnie zapisywać je na dysku jako surowy plik, minia

5Ciepło

2Odpowiedz

siły roboczej o Akka strumieni

Jak opisano akka streams documentation że próbował utworzyć pulę robocze (przepływów) def balancer[In, Out](worker: Flow[In, Out, NotUsed], workerCount: Int): Flow[In, Out, NotUsed] = { import Gr

5Ciepło

1Odpowiedz

Strumień Akka Stream vs Spark

Jakie są zalety/wady stosowania strumienia akka vs strumień iskier do przetwarzania strumienia? jak, wbudowane przeciwciśnienie, wydajność, odporność na awarie, wbudowane transformacje, elastyczność i

7Ciepło

2Odpowiedz

akka-http: pełne żądanie z przepływem

Załóżmy, że skonfigurowałem dowolnie złożony kod Flow[HttpRequest, HttpResponse, Unit]. mogę już używać wspomnianego przepływu do obsługi żądań przychodzących z Http().bindAndHandle(flow, "0.0.0.0", 8

7Ciepło

2Odpowiedz

W jaki sposób wykorzystywane są strumienie reaktywne używane w programie Slick do wstawiania danych?

W przykładach korzystania ze strumieni reaktywnych przedstawiono tylko dane do odczytu w charakterze DatabasePublisher. Ale co się dzieje, gdy chcesz używać bazy danych jako Zlewu i zwrotu wstecznego

5Ciepło

1Odpowiedz

Strumień Akka - ustawianie przepływu IO na innym dyktafonie

Mój strumień ma równomierne połączenie etapów związanych z CPU i IO (po każdym etapie IO następuje etap CPU). Co chcę zrobić, to umieścić operacje we/wy na innym dyspozytorze niż reszta strumienia. W