org.springframework.core.io.buffer

Class DataBufferUtils.WriteCompletionHandler

java.lang.Object

<any>

org.springframework.core.io.buffer.DataBufferUtils.WriteCompletionHandler

All Implemented Interfaces:

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

Enclosing class:

DataBufferUtils

private static class DataBufferUtils.WriteCompletionHandler
extends <any>
implements java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer>

Field Summary

Fields

Modifier and Type	Field and Description
private java.nio.channels.AsynchronousFileChannel	channel
private java.util.concurrent.atomic.AtomicBoolean	completed
private java.util.concurrent.atomic.AtomicReference<DataBuffer>	dataBuffer
private java.util.concurrent.atomic.AtomicReference<java.lang.Throwable>	error
private java.util.concurrent.atomic.AtomicLong	position
private <any>	sink

Constructor Summary

Constructors

Constructor and Description
WriteCompletionHandler(<any> sink, java.nio.channels.AsynchronousFileChannel channel, long position)

Method Summary

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 void	sinkDataBuffer()

Methods inherited from class java.lang.Object

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

Field Detail

sink

private final <any> sink

channel

private final java.nio.channels.AsynchronousFileChannel channel

completed

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

error

private final java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> error

position

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

dataBuffer

private final java.util.concurrent.atomic.AtomicReference<DataBuffer> dataBuffer

Constructor Detail

WriteCompletionHandler

public WriteCompletionHandler(<any> sink,
                              java.nio.channels.AsynchronousFileChannel channel,
                              long position)

Method Detail

hookOnSubscribe

protected void hookOnSubscribe(Subscription subscription)

hookOnNext

protected void hookOnNext(DataBuffer value)

hookOnError

protected void hookOnError(java.lang.Throwable throwable)

hookOnComplete

protected void hookOnComplete()

completed

public void completed(java.lang.Integer written,
                      java.nio.ByteBuffer byteBuffer)

Specified by:

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

failed

public void failed(java.lang.Throwable exc,
                   java.nio.ByteBuffer byteBuffer)

Specified by:

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

sinkDataBuffer

private void sinkDataBuffer()