Hello again,
My idea right now is to specify buffer size explicitly and return
Future[Try[Unit]] that indicates result of enqueuing into buffered source.
I am not sure that there is right way, but I need to connect some non
stream based system with akka streams. Any thoughts?
Unfortunately, I
Hi Alexey,
On Sat, Jan 24, 2015 at 11:20 AM, Alexey Romanchuk
alexey.romanc...@gmail.com wrote:
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
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
