Hey that's pretty nifty! In the meantime, Jeremy's silent actor publisher is working well.
Thanks, Peter On Monday, February 2, 2015 at 1:30:57 AM UTC-8, drewhk wrote: > > > > On Sun, Feb 1, 2015 at 9:05 PM, Jeremy Stone <[email protected] > <javascript:>> wrote: > >> Would something like the following in the server handler do it for you?... >> >> def silentSource = ??? // Source that emits nothing but does never >> completes >> def handleDataFromClient: ByteString => Unit = ??? >> >> ForeachSink[StreamTcp.IncomingConnection] { conn => >> println("Client connected from: " + conn.remoteAddress) >> >> silentSource.via(conn.flow).to(Sink.foreach(handleDataFromClient)). >> run >> } >> >> AFAIK there is no silent, non-completing Source implementation shipped >> with the akka streams library (1.0-M2). >> > > Now there is: https://github.com/akka/akka/pull/16750 > > Will be available in M3. > > -Endre > > >> We had a similar situation and had to create one using a very simple >> ActorPublisher. Alternatively, maybe first try it using a TickSource with a >> long initial delay. >> >> -- >> >>>>>>>>>> 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] <javascript:>. >> To post to this group, send email to [email protected] >> <javascript:>. >> Visit this group at http://groups.google.com/group/akka-user. >> For more options, visit 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 http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
