Topics tagged streams

Topic	Replies	Views	Activity
Is there is any way to cancel stream immidiatly Akka Libraries streams	5	536	January 19, 2021
How to get materialized value of a Flow you don't control? Akka Libraries akka , scala , websockets , streams	3	1332	January 6, 2021
Alpakka jms consumer throttle option Akka Streams & Alpakka akka , java , alpakka , streams	2	631	January 5, 2021
Bug or by design behavior ? Stoping a stream via KillSwitch + map combination Akka Streams & Alpakka streams	1	818	November 30, 2020
Commiting offsets for Kafka messages that are filtered Akka Streams & Alpakka akka , kafka , streams	1	1340	October 23, 2020
Using Flow as Sink/Source Akka Libraries akka-http , streams	2	932	October 16, 2020
Failing in one branch of the akka stream did not failed execution of another branch Akka Streams & Alpakka streams	1	479	October 8, 2020
Thread safety of Source.queue Akka Libraries streams	1	472	October 3, 2020
Attached / Non-Async TestSource Akka Streams & Alpakka streams	1	422	September 10, 2020
MergeHub not completing stream Akka Streams & Alpakka streams	2	698	September 1, 2020
Resolve 1000+ DNS with async-dns without OOM error Akka Libraries akka , scala , streams	24	2591	September 1, 2020
How can I supervise an actor materialized out of an ActorSource? Akka Libraries akka , streams	1	481	July 30, 2020
Why am I getting an overloaded method error, and how can I fix it? Akka Libraries akka , scala , streams	0	486	July 27, 2020
Convert a Flow[In, Out, Mat] into a Flow[In, Try[Out], NotUsed] Akka Streams & Alpakka streams	5	897	July 13, 2020
AWS S3 multipart upload with Akka Http does not upload the full file Akka Libraries akka-http , scala , streams	2	1483	June 26, 2020
Kafka - Ability to react on message publication result Akka Streams & Alpakka kafka , streams	17	4145	June 25, 2020
Custom EntityStreamingSupport Akka HTTP akka-http , scala , streams	1	631	June 22, 2020
Use a single source multiple times Akka Streams & Alpakka akka , scala , streams	6	1781	June 10, 2020
[Akka-Stream] How to let the groupBy operator without limited substreams? Akka Streams & Alpakka streams	2	597	June 3, 2020
How to configure Flow on the fly? Akka Streams & Alpakka streams	3	637	May 22, 2020
Combine MergeHub with MergePrioritized Akka Streams & Alpakka streams	0	658	May 22, 2020
How can I make sure that `FileIO.fromPath` is picking up my dispatcher? Akka Streams & Alpakka streams	5	1145	May 22, 2020
Is it possible to use ProducerMessage.passThrough with Transaction flow in Alpakka kafka? Akka Streams & Alpakka akka , kafka , streams	0	1000	May 15, 2020
Sequential processing is faster than parallel processing - Why? Akka Streams & Alpakka streams	2	1412	May 7, 2020
Slowing down processing on business errors Akka Streams & Alpakka kafka , alpakka , reactive-kafka , streams	5	3272	April 28, 2020
Optimizing akka stream throughput with multiple slow flows Akka Libraries streams	0	834	April 21, 2020
How to test typed actors that materialize streams Akka Libraries akka-typed , streams	2	1629	April 20, 2020
Iteratively create and concat Sources based on previous Source output Akka Libraries streams	4	866	April 9, 2020
Sftp error - Dying because - Idle connection Akka Streams & Alpakka scala , streams	1	1684	March 30, 2020
getFromBrowseableDirectories Akka HTTP akka , akka-http , streams	1	554	March 4, 2020