private static class DataBufferUtils.AsynchronousFileChannelWriteCompletionHandler
extends <any>
implements java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer>
Modifier and Type | Field and Description |
---|---|
private java.nio.channels.AsynchronousFileChannel |
channel |
private java.util.concurrent.atomic.AtomicBoolean |
completed |
private DataBuffer |
dataBuffer |
private java.util.concurrent.atomic.AtomicLong |
position |
private <any> |
sink |
Constructor and Description |
---|
AsynchronousFileChannelWriteCompletionHandler(<any> sink,
java.nio.channels.AsynchronousFileChannel channel,
long position) |
Modifier and Type | Method and Description |
---|---|
void |
completed(java.lang.Integer written,
java.nio.ByteBuffer byteBuffer) |
void |
failed(java.lang.Throwable exc,
java.nio.ByteBuffer byteBuffer) |
protected void |
hookOnComplete() |
protected void |
hookOnError(java.lang.Throwable throwable) |
protected void |
hookOnNext(DataBuffer value) |
protected void |
hookOnSubscribe(Subscription subscription) |
private final <any> sink
private final java.nio.channels.AsynchronousFileChannel channel
private final java.util.concurrent.atomic.AtomicBoolean completed
private final java.util.concurrent.atomic.AtomicLong position
@Nullable private DataBuffer dataBuffer
public AsynchronousFileChannelWriteCompletionHandler(<any> sink, java.nio.channels.AsynchronousFileChannel channel, long position)
protected void hookOnSubscribe(Subscription subscription)
protected void hookOnNext(DataBuffer value)
protected void hookOnError(java.lang.Throwable throwable)
protected void hookOnComplete()
public void completed(java.lang.Integer written, java.nio.ByteBuffer byteBuffer)
completed
in interface java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer>
public void failed(java.lang.Throwable exc, java.nio.ByteBuffer byteBuffer)
failed
in interface java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer>