> > Since you do not want to produce ticks at all if the previous source is > still not complete, I think you will have to fallback to ActorPublisher and > implement it. >
Thanks, i did so Can you specify this further? Also I would be happy to know the actual > use-case because nesting streams is usually a road to much pain if not done > carefully so I would investigate first if there is a >graph alternative for > the use-case. > There are an infinite source and a source that should be periodiclly runnnig with interval. Both sources should be processed in the one stream for the properly back pressure. For this purpose, i represent periodiclly running source as infinite source. I implemented that <https://gist.github.com/brs-lphv/456a22a3d64ecb5002c6#file-periodicsourcerunner-scala> with the PublisherActor as recommended Martynas and use like: val source = PeriodicSourceRunner( initialDelay = 1.millis, interval = period, createSource = () => createFullscanSource ).flatten(FlattenStrategy.concat) пятница, 23 января 2015 г., 20:52:10 UTC+4 пользователь drewhk написал: > > > > On Fri, Jan 23, 2015 at 5:45 PM, Martynas Mickevičius < > martynas.m...@typesafe.com <javascript:>> wrote: > >> There was a discussion on a similar but not completely exact topic that >> you described here <https://github.com/akka/akka/issues/16454>. >> > > umm, no, that is slightly different if I understood the proposal correctly. > > >> >> Since you do not want to produce ticks at all if the previous source is >> still not complete, I think you will have to fallback to ActorPublisher and >> implement it. >> >> On Thu, Jan 22, 2015 at 9:11 PM, Boris Lopukhov <89b...@gmail.com >> <javascript:>> wrote: >> >>> Hi all! >>> >>> How can i do a Source[Source[String]] that periodically emit the >>> Source[String] with the specified interval, but only if the previous >>> Source[String] is complete? >>> >> > Can you specify this further? Also I would be happy to know the actual > use-case because nesting streams is usually a road to much pain if not done > carefully so I would investigate first if there is a graph alternative for > the use-case. > > -Endre > > > >> >>> -- >>> >>>>>>>>>> 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 akka-user+...@googlegroups.com <javascript:>. >>> To post to this group, send email to akka...@googlegroups.com >>> <javascript:>. >>> Visit this group at http://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> >> >> -- >> Martynas Mickevičius >> Typesafe <http://typesafe.com/> – Reactive >> <http://www.reactivemanifesto.org/> Apps on the JVM >> >> -- >> >>>>>>>>>> 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 akka-user+...@googlegroups.com <javascript:>. >> To post to this group, send email to akka...@googlegroups.com >> <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 akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
