Hi Michael,
I assume your question is about how to get a Source[MyType] from such
streamed incoming entity?
The streaming and backpressure itself is “always on”, so the missing bit is
the marshalling — you are right we didn’t document it very well,
so I went ahead and added the docs:
Hi All-
I'm writing an application that must consume from a HTTP endpoint that
publishes a streaming response(the source app is using project
reactor/spring webflux).
I don't see any docs in the Akka-HTTP project that seem to map to my use
case. Does anyone know if it's possible to use akka
When another node with lower address is added. When there is a network
partition (unreachable).
Most often applications are more interested in using Cluster Singleton, and
that is not the same as leader.
If you have more questions I suggest that you post at the new
http://discuss.akka.io/