Description
When primary or peer WritableByteChannel#write throw exception, we should return it to client.
static long writeTo(ByteBuf buf, DataStream stream) { final WritableByteChannel channel = stream.getWritableByteChannel(); long byteWritten = 0; for (ByteBuffer buffer : buf.nioBuffers()) { try { byteWritten += channel.write(buffer); } catch (Throwable t) { throw new CompletionException(t); } } return byteWritten; }
Attachments
Attachments
Issue Links
- links to