Source.actorRef and Sink.actorRef both allows for integration with actors without custom graph stages, so you could use those to interact with DistributedPubSub in various ways. If you have special needs to can likely use the actor integration in GraphStage as described here in the docs: http://doc.akka.io/docs/akka/current/scala/stream/stream-customize.html#integration-with-actors
-- Johan Akka Team On Fri, Jun 2, 2017 at 4:39 AM, Yi Wang <[email protected]> wrote: > Hi all, > > Is there any way to combine custom GraphStage with Distributed Publish > Subscribe ? > > I'm refactoring a ActorPublisher into a GraphStage. > > Thanks a lot > > -- > >>>>>>>>>> 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 https://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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
