Hi Mike, There currently is no such stage, something like dynamic pub-sub (we have some ideas that you can read about in this ticket: https://github.com/akka/akka/issues/19478 <https://github.com/akka/akka/issues/19478>), so to do that you would have to either write your own stage for it or do it with actors (but then you loose backpressure).
-- Johan Andrén Akka Team, Lightbend Inc. > 20 apr. 2016 kl. 09:58 skrev Mike Limansky <[email protected]>: > > Hi Johan, > > I meant I'd like to merge data from all incoming connections to one output. > > > > вторник, 19 апреля 2016 г., 21:50:18 UTC+3 пользователь Johan Andrén написал: > Hi Mike, > > The problem is that you create one outgoing connection, but you cannot use > that more than once. If you move that logic to create a new outgoing > connection on every new incoming it will work better, so that would be inside > of your foreach. > > Please take a look at the docs for doing IO with Streams here: > http://doc.akka.io/docs/akka/2.4.4/scala/stream/stream-io.html#Streaming_TCP > <http://doc.akka.io/docs/akka/2.4.4/scala/stream/stream-io.html#Streaming_TCP> > > (I think that will answer most of your questions) > > -- > Johan Andrén > Akka Team, Lightbend Inc. > > On Tuesday, April 19, 2016 at 5:44:27 PM UTC+2, Mike Limansky wrote: > Hi all, > > I'm very new to Akka Streams, trying to get the ideas behind the streams > and how to use them. I'd like to make a very simple thing: to connect two TCP > server sockets, but I get stuck with that. > > If I have server and client connections, it more or less clear for me: > > val conn = Tcp().bind("localhost", 1234) > val out = Tcp().outgoingConnection("localhost", 2345) > > val handler = Sink.foreach[Tcp.IncomingConnection] { c => > println("Got connection from " + c.remoteAddress) > c.handleWith(out) > } > > conn.to(handler).run() > > > This working for one connection. Could anybody give me a clue how to get it > work with more that one incoming connections (I suppose I need to use Merge, > or Source.combine)? > > And the second question. As I understand this works in one direction (from > server socket to client). How can I use BidiFlow in such situation? > > Finally, If I have two server connections I have no idea how to achieve > same result. Should I use mutable state to store incoming connections? > > -- > BR, > Mike. > > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ <http://akka.io/docs/> > >>>>>>>>>> Check the FAQ: > >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>>>>>>> <http://doc.akka.io/docs/akka/current/additional/faq.html> > >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user > >>>>>>>>>> <https://groups.google.com/group/akka-user> > --- > You received this message because you are subscribed to a topic in the Google > Groups "Akka User List" group. > To unsubscribe from this topic, visit > https://groups.google.com/d/topic/akka-user/AvFbNTKMEdo/unsubscribe > <https://groups.google.com/d/topic/akka-user/AvFbNTKMEdo/unsubscribe>. > To unsubscribe from this group and all its topics, send an email to > [email protected] > <mailto:[email protected]>. > To post to this group, send email to [email protected] > <mailto:[email protected]>. > Visit this group at https://groups.google.com/group/akka-user > <https://groups.google.com/group/akka-user>. > For more options, visit https://groups.google.com/d/optout > <https://groups.google.com/d/optout>. -- >>>>>>>>>> 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/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
