org.springframework.core.io.buffer

Class DataBufferUtils.ReadCompletionHandler

java.lang.Object

org.springframework.core.io.buffer.DataBufferUtils.ReadCompletionHandler

All Implemented Interfaces:

java.nio.channels.CompletionHandler<java.lang.Integer,DataBuffer>

Enclosing class:

DataBufferUtils

private static class DataBufferUtils.ReadCompletionHandler
extends java.lang.Object
implements java.nio.channels.CompletionHandler<java.lang.Integer,DataBuffer>

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
ReadCompletionHandler(java.nio.channels.AsynchronousFileChannel channel, <any> sink, long position, DataBufferFactory dataBufferFactory, int bufferSize)

Method Summary

Modifier and Type	Method and Description
private void	complete()
void	completed(java.lang.Integer read, DataBuffer dataBuffer)
void	dispose()
void	failed(java.lang.Throwable exc, DataBuffer dataBuffer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

channel

private final java.nio.channels.AsynchronousFileChannel channel

sink

private final <any> sink

dataBufferFactory

private final DataBufferFactory dataBufferFactory

bufferSize

private final int bufferSize

position

private final java.util.concurrent.atomic.AtomicLong position

disposed

private final java.util.concurrent.atomic.AtomicBoolean disposed

Constructor Detail

ReadCompletionHandler

public ReadCompletionHandler(java.nio.channels.AsynchronousFileChannel channel,
                             <any> sink,
                             long position,
                             DataBufferFactory dataBufferFactory,
                             int bufferSize)

Method Detail

completed

public void completed(java.lang.Integer read,
                      DataBuffer dataBuffer)

Specified by:

completed in interface java.nio.channels.CompletionHandler<java.lang.Integer,DataBuffer>

complete

private void complete()

failed

public void failed(java.lang.Throwable exc,
                   DataBuffer dataBuffer)

Specified by:

failed in interface java.nio.channels.CompletionHandler<java.lang.Integer,DataBuffer>

dispose

public void dispose()