Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in akka-stream

How to effectively read millions of rows from Cassandra?

Consume TCP stream and redirect it to another Sink (with Akka Streams)

scala tcp akka akka-stream

Akka flow for multiple http requests

http => akka stream => http

What is an idiomatic way to filter out Either Left in an akka stream?

scala akka akka-stream either

How to attach multiple actors as sources to an Akka stream?

akka akka-stream

How to respond with the result of an actor call?

java akka-stream akka-http

How do I dynamically add Source to existing Graph?

scala akka akka-stream

Streaming file from server to client using Akka

akka-http: send element to akka sink from http route

scala akka-stream akka-http

Akka Stream: what does mapMaterializedValue mean

java promise 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

Akka Streams: State in a flow

Creating a flow from actor in Akka Streams

scala akka akka-stream