Hey hakkers,
I wonder why there is not such prebuilt Source that provides API to
externally emit message by simple method call. I am talking about something
like this:
//building and starting flow
val flow = ???
val source = ExternalSource[String]
source.via(flow).to(BlackholeSink).run
//using source
source.emit("")
source.complete()
source.error(new Exception)
It can be implemented manually using actor, buffer inside it and exposing
some object that internally sends message to this actor. I think this
source can be very useful in case of integration with external API.
Thanks
p.s. Sure, we can not directly use ExternalSource to emit objects, but
should use some object created during flow materialization, like PropSource
does.
--
>>>>>>>>>> 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 http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
