By looking at the API of akka.stream.actor.AbstractActorPublisher I conclude that it only reacts to ActorPublisherMessage.Request messages.
It always has to first receive a ActorPublisherMessage.Request before it can send data by onNext(). Please forgive if I am wrong but I thought that "Reactive Streams specification" also allows a Publisher to actively push data downstream. (of course if it pushes too fast it will receive a throttling message) This seems to not be possible with the current akka.stream.actor.AbstractActorPublisher API? -- >>>>>>>>>> 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.
