Issue #2592 - Rework of WriteFlusher
changes from review Signed-off-by: Lachlan Roberts <lachlan@webtide.com>
This commit is contained in:
parent
f2893fdd0b
commit
da58c20d90
|
@ -260,6 +260,12 @@ abstract public class WriteFlusher
|
||||||
{
|
{
|
||||||
callback = Objects.requireNonNull(callback);
|
callback = Objects.requireNonNull(callback);
|
||||||
|
|
||||||
|
if(isFailed())
|
||||||
|
{
|
||||||
|
fail(callback);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
if (DEBUG)
|
if (DEBUG)
|
||||||
LOG.debug("write: {} {}", this, BufferUtil.toDetailString(buffers));
|
LOG.debug("write: {} {}", this, BufferUtil.toDetailString(buffers));
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue