search

ReactiveX / RxNetty

Reactive Extension (Rx) Adaptor for Netty
Apache License 2.0
1.38k stars 254 forks source link

Provide a way to avoid using `flushOnEach` for streaming writes #413

Open NiteshKant opened 9 years ago

NiteshKant commented 9 years ago

In cases, when there is a need to write infinite (or streams with unpredictable lengths) on a connection, the only practical way to flush data is to use flushOnEach as coming to an adequate buffer size/ time boundary is just too hard and error prone.

It would be nice to be able to tell RxNetty to flush all pending writes on the next eventloop iteration. It should still be possible to issue explicit flush() but in absence of an explicit flush, the writes must be flushed with every eventloop iteration.

NiteshKant commented 8 years ago

Netty is adding Auto-Flush support. Related PR: https://github.com/netty/netty/pull/5395

jamesgorman2 commented 8 years ago

Nice one, be good to see that in