akka-stream-CodePudding

Tags > akka-stream

08-20Software designHow to divert Future failure in Akka stream to a separate sink?
07-28Back-endAkka Streams - How do I create a runnable Graph dynamically at runtime?
07-27Back-endakka-stream pipeline backpressures despite inserted buffer
07-26Software designakka-stream pipeline backpressures desipite inserted buffer
06-27Software designAkka stream stops processing data
04-25Software engineeringjava.lang.NoSuchMethodError: 'void akka.actor.ExtensionId.$init$(akka.actor.ExtensionId)'
04-21OSAkka streams - why is an ActorSystem accepted as a Materalizer only when it is marked as implicit?
04-19BlockchainDynamic Akka streams sink
03-30Back-endAkka Source that emits when another Sink receives
02-26EnterpriseAkka stream hangs when starting more than 15 external processes using ProcessBuilder
12-21otherAkka streams websocket stream things to a Sink.seq ends with exception SubscriptionWithCancelExcepti
12-06OSValidating akka-stream Source in unit test
12-05Software engineeringHow to unmarshall json response removing unnecessary fields using Akka HTTP
12-01BlockchainAkka - convert Flow into Collection or Publisher
11-29OSAkka Streams: How to form inlets and outlets for a Graph using a Flow
11-26Back-endHow to handle backpressure when Streaming file from s3 with actor interop
11-22Software designAkka Stream continuously consume websocket
10-28OSConcatinating two Flows in Akka stream
10-28OSactor getting BufferOverflowException when sending Single
10-25Software engineeringUse a Actor as a source to my Websocket client flow
10-25otheractor getting BufferOverflowException when sending Single
10-22otherUse a Actor as a source to my Websocket client flow
10-22otherConcatinating two Flows in Akka stream
10-21NetHow to keep my incoming websocket connection open all the time?
10-17databaseHow to map parquet record (json) to case class using alpakka
10-15BlockchainHow do I send multiple messages as my source
10-12OSakka streaming file lines to actor router and writing with single actor. how to handle the backpress
10-05BlockchainWrapping Pub-Sub Java API in Akka Streams Custom Graph Stage
10-03OSScala Akka (un)marshalling nested Seq collections with Spray JSON
10-01NetHow to generate the materialized value from the elements in Source or Flow?