Hi Gary,
Until the Sink does not call pull() automatically, and it will not receive
an onPush without explicitly pulling its upstream first - this is the
backpressure part.
You can simply call pull(in) by overriding preStart() and calling it from
there. This is not done automatically by the frame
Thx, I though it will be some simpler method around, but I will try jnr. I
will not create any generic wrappers, have no time for this, and I will
probably never use these code again ;)
Regards,
Daniel
2016-02-16 14:40 GMT+01:00 Rafał Krzewski :
> https://github.com/kohlschutter/junixsocket lib
I wondered how hard could it be to write akka-remote transport using
akka.io only.
It turned out that it is not that hard to start:
https://github.com/marekzebrowski/akka-remote-io
roughly ~ 200 lines for proof of concept tcp implementation
probably I'm doing something wrong as simple test case
