Topics tagged streams

Topic	Replies	Views	Activity
Is there is any way to cancel stream immidiatly Akka streams	5	503	January 19, 2021
How to get materialized value of a Flow you don't control? Akka akka , scala , websockets , streams	3	1303	January 6, 2021
Alpakka jms consumer throttle option Akka Streams & Alpakka akka , java , alpakka , streams	2	619	January 5, 2021
Serving files (returning input stream) causes Timeout waiting for connection from pool Play Framework akka , streams	0	585	December 16, 2020
Akka persistence Cassandra throwing ask timeouts after writing few million events Lagom akka , streams	1	852	December 12, 2020
Bug or by design behavior ? Stoping a stream via KillSwitch + map combination Akka Streams & Alpakka streams	1	796	November 30, 2020
Commiting offsets for Kafka messages that are filtered Akka Streams & Alpakka akka , kafka , streams	1	1279	October 23, 2020
Using Flow as Sink/Source Akka akka-http , streams	2	889	October 16, 2020
Failing in one branch of the akka stream did not failed execution of another branch Akka Streams & Alpakka streams	1	470	October 8, 2020
Thread safety of Source.queue Akka streams	1	464	October 3, 2020
Create Source from Lagom kafka subscriber Lagom kafka , alpakka , streams	0	496	September 18, 2020
"Typed"ActorFlow Play Framework akka-typed , websockets , streams	0	771	September 16, 2020
Attached / Non-Async TestSource Akka Streams & Alpakka streams	1	414	September 10, 2020
MergeHub not completing stream Akka Streams & Alpakka streams	2	688	September 1, 2020
Resolve 1000+ DNS with async-dns without OOM error Akka akka , scala , streams	24	2563	September 1, 2020
How can I supervise an actor materialized out of an ActorSource? Akka akka , streams	1	477	July 30, 2020
Why am I getting an overloaded method error, and how can I fix it? Akka akka , scala , streams	0	481	July 27, 2020
Convert a Flow[In, Out, Mat] into a Flow[In, Try[Out], NotUsed] Akka Streams & Alpakka streams	5	878	July 13, 2020
AWS S3 multipart upload with Akka Http does not upload the full file Akka akka-http , scala , streams	2	1460	June 26, 2020
Kafka - Ability to react on message publication result Akka Streams & Alpakka kafka , streams	17	4094	June 25, 2020
Custom EntityStreamingSupport Akka HTTP akka-http , scala , streams	1	621	June 22, 2020
Use a single source multiple times Akka Streams & Alpakka akka , scala , streams	6	1685	June 10, 2020
[Akka-Stream] How to let the groupBy operator without limited substreams? Akka Streams & Alpakka streams	2	582	June 3, 2020
How to configure Flow on the fly? Akka Streams & Alpakka streams	3	629	May 22, 2020
Combine MergeHub with MergePrioritized Akka Streams & Alpakka streams	0	648	May 22, 2020
How can I make sure that `FileIO.fromPath` is picking up my dispatcher? Akka Streams & Alpakka streams	5	1130	May 22, 2020
Is it possible to use ProducerMessage.passThrough with Transaction flow in Alpakka kafka? Akka Streams & Alpakka akka , kafka , streams	0	991	May 15, 2020
Sequential processing is faster than parallel processing - Why? Akka Streams & Alpakka streams	2	1334	May 7, 2020
Slowing down processing on business errors Akka Streams & Alpakka kafka , alpakka , reactive-kafka , streams	5	3256	April 28, 2020
Optimizing akka stream throughput with multiple slow flows Akka streams	0	806	April 21, 2020