Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in akka-stream

Converting a callback-method implementation into an akka stream Source

scala akka akka-stream

How can Akka streams be materialized continually?

How to retry failed Unmarshalling of a stream of akka-http requests?

Sink for line-by-line file IO with backpressure

scala akka akka-stream

Filter async with akka-stream

scala akka akka-stream

Idiomatic way to use Spark DStream as Source for an Akka stream

Why Source.fromIterator expects a Function0[Iterator[T]] as a parameter instead of Iterator[T]?

scala akka-stream

Understanding NotUsed and Done

scala akka akka-stream

End-to-End Reactive Streaming RESTful service (a.k.a. Back-Pressure over HTTP)

Akka stream - List to mapAsync of individual elements

scala akka akka-stream

Akka streams: dealing with futures within graph stage

scala akka akka-stream

Akka streams: Reading multiple files

scala akka akka-stream

Akka Streams: How do I get Materialized Sink output from GraphDSL API?

scala akka-stream

How does one control the flow of an Akka Stream based on another stream

akka-stream

Is there a way to get predictable actor naming with Akka-Stream?

scala akka akka-stream

Why Play 2.5 Akka chunk response getting loaded all at once