Take a look at MergeHub. It's rather new.
http://doc.akka.io/docs/akka/2.4/scala/stream/stream-dynamic.html
/Patrik
lör 24 sep. 2016 kl. 00:53 skrev oleksiys :
> Hi guys,
>
> I need to merge mutliple sources Seq[Source[A, Mat]] and as an output get
> something like Source[A, Seq[Mat]].
> For now
If all nodes in cluster is normal node, none is seed.
How to set one of nodes as seed please?
I can't do this, no new node can join the cluster.
Thanks
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additiona
Originally on 2.4.7, but I just checked with 2.4.10 and I get the same
result.
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the archives: https://groups.google.com
Here's the code I'm using:
https://gist.github.com/danellis/11017d58496a80e0b0d63e2581c20d2d
When a client connects, I get this in the log:
04:05:17.732 DEBUG akka.io.TcpListener - New connection accepted
04:05:17.866 DEBUG akka.actor.ActorSystemImpl - Creating WebSocket inbound
actor
04:05:1