org.springframework.core.io.buffer

Class DataBufferUtils.WritableByteChannelSubscriber

java.lang.Object

<any>

org.springframework.core.io.buffer.DataBufferUtils.WritableByteChannelSubscriber

Enclosing class:

DataBufferUtils

private static class DataBufferUtils.WritableByteChannelSubscriber
extends <any>

Field Summary

Fields

Modifier and Type	Field and Description
private java.nio.channels.WritableByteChannel	channel
private <any>	sink

Constructor Summary

Constructors

Constructor and Description
WritableByteChannelSubscriber(<any> sink, java.nio.channels.WritableByteChannel channel)

Method Summary

Modifier and Type	Method and Description
protected void	hookOnComplete()
protected void	hookOnError(java.lang.Throwable throwable)
protected void	hookOnNext(DataBuffer dataBuffer)
protected void	hookOnSubscribe(Subscription subscription)

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.WritableByteChannel channel

Constructor Detail

WritableByteChannelSubscriber

public WritableByteChannelSubscriber(<any> sink,
                                     java.nio.channels.WritableByteChannel channel)

Method Detail

hookOnSubscribe

protected void hookOnSubscribe(Subscription subscription)

hookOnNext

protected void hookOnNext(DataBuffer dataBuffer)

hookOnError

protected void hookOnError(java.lang.Throwable throwable)

hookOnComplete

protected void hookOnComplete()