private static class DataBufferUtils.AsynchronousFileChannelReadCompletionHandler extends java.lang.Object implements java.nio.channels.CompletionHandler<java.lang.Integer,DataBuffer>
Modifier and Type | Field and Description |
---|---|
private int |
bufferSize |
private java.nio.channels.AsynchronousFileChannel |
channel |
private DataBufferFactory |
dataBufferFactory |
private java.util.concurrent.atomic.AtomicBoolean |
disposed |
private java.util.concurrent.atomic.AtomicLong |
position |
private <any> |
sink |
Constructor and Description |
---|
AsynchronousFileChannelReadCompletionHandler(java.nio.channels.AsynchronousFileChannel channel,
<any> sink,
long position,
DataBufferFactory dataBufferFactory,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
void |
completed(java.lang.Integer read,
DataBuffer dataBuffer) |
void |
failed(java.lang.Throwable exc,
DataBuffer dataBuffer) |
private final java.nio.channels.AsynchronousFileChannel channel
private final <any> sink
private final DataBufferFactory dataBufferFactory
private final int bufferSize
private final java.util.concurrent.atomic.AtomicLong position
private final java.util.concurrent.atomic.AtomicBoolean disposed
public AsynchronousFileChannelReadCompletionHandler(java.nio.channels.AsynchronousFileChannel channel, <any> sink, long position, DataBufferFactory dataBufferFactory, int bufferSize)
public void completed(java.lang.Integer read, DataBuffer dataBuffer)
completed
in interface java.nio.channels.CompletionHandler<java.lang.Integer,DataBuffer>
public void failed(java.lang.Throwable exc, DataBuffer dataBuffer)
failed
in interface java.nio.channels.CompletionHandler<java.lang.Integer,DataBuffer>