org.springframework.http.server.reactive

Class AbstractListenerWriteProcessor<T>

java.lang.Object

org.springframework.http.server.reactive.AbstractListenerWriteProcessor<T>

All Implemented Interfaces:

org.reactivestreams.Processor<T,Void>, org.reactivestreams.Publisher<Void>, org.reactivestreams.Subscriber<T>

Direct Known Subclasses:

AbstractListenerWebSocketSession.WebSocketSendProcessor

public abstract class AbstractListenerWriteProcessor<T>
extends Object
implements org.reactivestreams.Processor<T,Void>

Abstract base class for Processor implementations that bridge between event-listener write APIs and Reactive Streams.

Specifically a base class for writing to the HTTP response body with Servlet 3.1 non-blocking I/O and Undertow XNIO as well for writing WebSocket messages through the Java WebSocket API (JSR-356), Jetty, and Undertow.

Since:

5.0

Author:

Arjen Poutsma, Violeta Georgieva, Rossen Stoyanchev

Field Summary

Fields

Modifier and Type	Field and Description
protected T	currentData
protected Log	logger

Constructor Summary

Constructors

Constructor and Description
AbstractListenerWriteProcessor()

Method Summary

Modifier and Type	Method and Description
void	cancel() Listeners can call this method to cancel further writing.
protected abstract boolean	isDataEmpty(T data) Whether the given data item contains any actual data to be processed.
protected abstract boolean	isWritePossible() Whether writing is possible.
void	onComplete()
void	onError(Throwable t)
void	onNext(T data)
void	onSubscribe(org.reactivestreams.Subscription subscription)
void	onWritePossible() Listeners can call this to notify when writing is possible.
protected void	receiveData(T data) Called when a data item is received via Subscriber.onNext(Object)
protected abstract void	releaseData() Called when the current received data item can be released.
void	subscribe(org.reactivestreams.Subscriber<? super Void> subscriber)
protected abstract boolean	write(T data) Writes the given data to the output.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final Log logger

currentData

protected volatile T currentData

Constructor Detail

AbstractListenerWriteProcessor

public AbstractListenerWriteProcessor()

Method Detail

onSubscribe

public final void onSubscribe(org.reactivestreams.Subscription subscription)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

onNext

public final void onNext(T data)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

onError

public final void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

onComplete

public final void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>

subscribe

public final void subscribe(org.reactivestreams.Subscriber<? super Void> subscriber)

Specified by:

subscribe in interface org.reactivestreams.Publisher<Void>

onWritePossible

public final void onWritePossible()

Listeners can call this to notify when writing is possible.

cancel

public void cancel()

Listeners can call this method to cancel further writing.

receiveData

protected void receiveData(T data)

Called when a data item is received via Subscriber.onNext(Object)

releaseData

protected abstract void releaseData()

Called when the current received data item can be released.

isDataEmpty

protected abstract boolean isDataEmpty(T data)

Whether the given data item contains any actual data to be processed.

isWritePossible

protected abstract boolean isWritePossible()

Whether writing is possible.

write

protected abstract boolean write(T data)
                          throws IOException

Writes the given data to the output.

Parameters:

data - the data to write

Returns:

whether the data was fully written (true)and new data can be requested or otherwise (false)

Throws:

IOException