Search code examples
Akka FileIO.fromPath - How to deal with IOResult and get the data instead?...

scalaakka-stream

Read More
Akka stream not processing all the lines from my CSV file...

scalacsvakkaakka-streamthrottling

Read More
How to reduce `.via()` down a Seq of custom GraphStage?...

scalaakkaakka-stream

Read More
Polling with Akka-Http stream...

scalaakkaakka-streamakka-http

Read More
Akka HTTP streaming API with cycles never completes...

akka-streamakka-http

Read More
Usage of Keep.right / Keep.left within Akka Streams does not affect the result...

scalaakka-stream

Read More
Complete route with source and get its materialised value...

akka-streamakka-http

Read More
Sliding window based on Akka actor source not behaving as expected...

javaakkaakka-stream

Read More
Add custom logic/callback/handler when EOF for JsonFraming in akka-streams...

scalaapache-kafkaakkaakka-stream

Read More
Adding state between operations within akka stream...

javaakkaakka-stream

Read More
Akka: Websocket handler failed with Cannot subscribe to shut-down Publisher...

scalaakkaakka-streamakka-http

Read More
How do you process a sequence of Akka Stream Sources?...

scalaakkaakka-stream

Read More
Looking for a real time streaming solution...

spark-streamingapache-kafka-streamsflink-streamingakka-stream

Read More
Akka Streams for server streaming (gRPC, Scala)...

scalaakkagrpcakka-streamakka-grpc

Read More
Is `BoundedSourceQueue` from `Source.queue` ok with concurrent producers?...

scalaakkaakka-stream

Read More
Consumer does not read messages from the Kafka topic (Akka Stream Kafka)...

javaapache-kafkajava-8akka-streamkafka-transactions-api

Read More
Is there any way to get Akka Streams' groupedWithin to emit empty groups?...

javaakkaakka-stream

Read More
Sending data to an Akka Stream...

javaakkaakka-stream

Read More
How to access the computation result of an Akka Stream?...

javaakkaakka-stream

Read More
Processing changing source data in Java Akka streams...

javascalaakkaakka-stream

Read More
Changing source data for akka streams...

javascalaakkaakka-stream

Read More
How to send a file as a response using akka http?...

scalaakkaakka-streamakka-http

Read More
akka stream design pattern for files consumption...

scalaakkaakka-streamreactive-streams

Read More
Adjusting parallism based on number of partitions assigned in Consumer.committablePartitionedSource...

javaakka-streamalpakka

Read More
What is the Akka streams .via() equivalent in Project Reactor?...

javascalaproject-reactorakka-stream

Read More
Convert Akka Graph DSL Stream return type to Future[T] Instead of T (Wait)...

scalaakkaakka-stream

Read More
Why Akka streams cycle doesn't end in this graph?...

scalagraphcycleakka-stream

Read More
akka-streams stateful substream flow...

scalaakkaakka-stream

Read More
Akka Stream - Parallel Processing with Partition...

scalaakkaakka-stream

Read More
Timeout Akka Streams Flow...

scalaakkaakka-stream

Read More
BackNext