On Tuesday, December 22, 2015 at 5:17:09 PM UTC+1, Konrad Malawski wrote: > > > I'll leave the semantics questions to Roland or Endre to tackle (in > general it should not change semantics), but a few quick ones: > > > 2. how to insert async boundaries in linear pipelines? E.g.: > > Source(List(1, 2, 3)) > .map(_ + 1) > .addAttributes(Attributes.asyncBoundary) > .map(_ * 2) > > doesn't compile > > Source(List(1,2,3)).map(identity).withAttributes(Attributes.asyncBoundary).map(identity) > > Docs about it will come soon. >
Thanks! :) I guess the addAttributes variant could be hidden. > 4. which built-in stages are fuseable by default? The docs are quite vague > here saying only "linear" ones. Which ones are these? > > Where is that stated? That's outdated info. > > Almost all default stages are (except TLS Stage and very specialised > ones), that's explained here: (in the docs) > https://github.com/akka/akka/commit/f613ef17e25a9e6b005edae925cc1ff75cf87ae9 > I've read this: http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0/scala/migration-guide-1.0-2.x-scala.html, linked from the blog. This says that: "Fusable elements are * all GraphStages (this includes all built-in junctions apart from groupBy) * all Stages (this includes all built-in linear operators)" though I'm not sure which elements are linear, stages or graph stages (from the available API) Thanks, Adam -- >>>>>>>>>> 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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
