Hi Bogdan, in M4 we changed the graph DSL to be "more typed" (we like types :-)), a brief introduction can be found in the announcement email: https://groups.google.com/forum/#!topic/akka-user/8UNq8QdkYoI
Please do remember that the milestones are considered pre-alpha, everything can change, quite drastically. These releases are aimed to gather feedback and stabilize the best possible API in 1.0 - thus the big changes. Not all docs have been cleaned up yet - we'll catch up on these very soon! (There will be way more docs, a lot more - soon). Hope this helps! -- Konrad W dniu piątek, 6 marca 2015 11:08:14 UTC+1 użytkownik Bogdan Nechyporenko napisał: > > I'm updating from > > com.typesafe.akka:akka-stream-experimental_2.10:1.0-M4 > > to > > com.typesafe.akka:akka-stream-experimental_2.10:1.0-M4 > > but there are no classes like UndefinedSource, UndefinedSink, > BlackholeSink, SubscriberSink, OnCompleteSink and others. > > There is no documentation why it was removed and which approach to be > taken now instead of this class. > > Though in the documentation of this version I still see the notion of > UndefinedSource > > > http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M4/scala/stream-io.html > > > The way we constructed a Flow using a PartialFlowGraph is explained in > > detail in Constructing Sources, Sinks and Flows from Partial Graphs, > > however the basic concepts is rather simple– we can encapsulate > > arbitrarily complex logic within a Flow as long as it exposes the same > > interface, which means exposing exactly one UndefinedSink and exactly > > one UndefinedSource which will be connected to the TCP pipeline. In > > this example we use a Concat graph processing stage to inject the > > initial message, and then continue with handling all incoming data > > using the echo handler. You should use this pattern of encapsulating > > complex logic in Flows and attaching those to StreamIO in order to > > implement your custom and possibly sophisticated TCP servers. > > Seems to be that the documentation is wrong or some extra dependencies are > required now > -- >>>>>>>>>> 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.
