akka-stream
Jak utworzyć źródło, które może odbierać elementy później poprzez wywołanie metody?
Chciałbym utworzyć Source, a później wcisnąć na nim elementy, jak w:
val src = ... // create the Source here
// and then, do something like this
pushElement(x1, src)
pushElement(x2, src)
Jaki jest zalecany sposób, aby to zrobić?
Dzięki!
Tworzenie dopływu z Akki w strumieniach
Możliwe jest tworzenie źródeł i zlewozmywaków z aktorów przy użyciu odpowiednio metod Source.actorPublisher() i Sink.actorSub ... ogu jest zrobiony we wcześniejszej wersji streamów Akka, więc pytanie czy jest to możliwe również w najnowsza (2.4.9) wersja.
Jak używać źródła strumieniowego Akka z PlayFramework
Chciałbym użyć źródła do dynamicznego wepchnięcia elementów do źródła strumienia Akka.
Kontroler odtwarzania potrzebuje źródł ... (Source.fromPublisher(pub))
}
Czy istnieje prostszy sposób na użycie Źródła strumieniowego Akka z PlayFramework?
Dzięki
W strumieniach project reactor lub akka, jaka jest koncepcyjna różnica między sink a subscriber?
Pojęcia sink i subscriber wydają mi się podobne. Nie widzę też, by pojęcie zlewu było wyraźnie zdefiniowane w specyfikacji reactive streams.
Jak poprawnie wywołać klienta HTTP Akka dla wielu (10k - 100k) żądań?
Próbuję napisać narzędzie do wsadowego przesyłania danych za pomocą Akka HTTP 2.0-m2.
Ale stoję przed akka.stream.OverflowStr ... również nie pomogło.
Jaki jest prawidłowy sposób uruchamiania partii żądań? Planuję wykonać partie 10 000 - 100 000 prośby.
Jak pobrać zasób HTTP do pliku ze strumieniami Akka i HTTP?
W ciągu ostatnich kilku dni próbowałem znaleźć najlepszy sposób, aby pobrać zasób HTTP do pliku za pomocą strumieni Akka i HT ... ByteString, File)].map(_._1).toMat(sink)(Keep.right)
}
sourceWithDest.runWithMap {
case (_, file) => destToSink(file)
}