Re: [akka-user] Source.queue with java sample

Browse the docs :-) > > > https://doc.akka.io/japi/akka/current/akka/stream/javadsl/Source.html#queue-int-akka.stream.OverflowStrategy- > > > > -- > Cheers, > Konrad 'ktoso <http://kto.so>' Malawski > Akka <http://akka.io/> @ Lightbend <http://lightb

[akka-user] Source.queue with java sample

I cannot find a Source.queue with java sample,does anyone has? please! -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives:

[akka-user] Re: Accessing SourceQueue or ActorRef inside Graph for publishing elements

use zip method On Sunday, 22 November 2015 23:49:14 UTC+8, Muki wrote: > > Hi, > > I have a stream pipeline like this: > > progress queue+-> mapping +-+ > | >^^^ | >|||

[akka-user] how to combine different flows and merge them when all the flows are reached in akka streams

how to combine different flows and merge them when all the flows are reached in akka streams? I want to merge all flows together at the same time ,which means I will wait until the last flow reached ,and merge the different flows into a large integrate flow? would you please help me ? thanks!!