You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Investigate use of backpressure for not immediately flushed datachunks as suggested by @olotenko :
Count the bytes that go through here, and allow up to a given amount to be buffered. Eg onNext counts how many bytes were in the buffers it has seen, and requests one more chunk if it has seen below watermark. Then channel.write completion Future subtracts the bytes it has just written. If this results in crossing the "watermark", then request 1. (because onNext stopped requesting more)
Watermarking approach is more predictable. Just deferring to channel.write completion would work poorly, if in the common case socket write completion does not happen during onNext, but will work better than watermarking, if there is this guarantee. (Ie that onNext attempts to call channel.write, through a few calls of intermediate routines, and that Netty completes the future before onNext returns, if the write fully fits in socket send buffers)
Investigate use of backpressure for not immediately flushed datachunks as suggested by @olotenko :
#3108 (review)
PR's
The text was updated successfully, but these errors were encountered: