sorry, Fold should be Flow Cheers, √ On 8 Jul 2015 18:41, "Allen Nie" <aiming...@gmail.com> wrote:
> Thank you Viktor, > > However, I still get this error: > > val withoutSink = source via graphFlows.fold(Fold[NormalRow, > NormalRow])(_ via _) > > > val runnableFlow = withoutSink to sink > > > "Error:(25, 54) object Fold in package fusing cannot be accessed in > package akka.stream.impl.fusing > val withoutSink = source via graphFlows.fold(Fold[NormalRow])(_ > via _) > ^ > " > > Fold is defined as a private class. Where should I import Fold? > > Thank you, > Allen Nie > > On Wednesday, July 8, 2015 at 4:26:10 AM UTC-4, √ wrote: >> >> val withoutSink = source via graphFlows.fold(Fold[NormalRow])(_ via _) >> >> val runnableFlow = withoutSink to sink >> >> runnableFlow.run() >> >> On Wed, Jul 8, 2015 at 2:35 AM, Allen Nie <aimi...@gmail.com> wrote: >> >>> Hi, >>> >>> I'm trying to construct a stream pipeline automatically based on a >>> list of Flow: >>> >>> val graphFlows: mutable.ListBuffer[Flow[NormalRow, NormalRow, Unit]] = >>> mutable.ListBuffer.empty[Flow[NormalRow, >>> NormalRow, Unit]] >>> >>> >>> The example given in stream cookbook chapter: >>> http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M4/scala/stream-cookbook.html >>> only talks about a fixed pool of workers and how to connect it to a >>> balancer. >>> >>> This is what my code looks like right now: >>> >>> val g = FlowGraph.closed(sink) { implicit builder: >>> FlowGraph.Builder => >>> >>> sink => >>> >>> import FlowGraph.Implicits._ >>> >>> graphFlows.foreach { flow => >>> source ~> flow >>> } >>> >>> } >>> >>> >>> I have no reason to believe this would work, and I don't even know >>> how to hook this up to a sink after the flow is chained with source. >>> >>> Can anyone shed some light on this? >>> >>> Sincerely, >>> Allen Nie >>> >>> -- >>> >>>>>>>>>> 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. >>> To post to this group, send email to akka...@googlegroups.com. >>> Visit this group at http://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> >> >> -- >> Cheers, >> √ >> > -- > >>>>>>>>>> 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. > -- >>>>>>>>>> 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.
