org.springframework.http.server.reactive

Class AbstractListenerWriteFlushProcessor.State.WriteResultSubscriber

java.lang.Object

org.springframework.http.server.reactive.AbstractListenerWriteFlushProcessor.State.WriteResultSubscriber

Enclosing class:

AbstractListenerWriteFlushProcessor.State

private static class AbstractListenerWriteFlushProcessor.State.WriteResultSubscriber
extends java.lang.Object

Subscriber to receive and delegate completion notifications for from the current Publisher, i.e. for the current flush boundary.

Field Summary

Fields

Modifier and Type	Field and Description
private AbstractListenerWriteFlushProcessor<?>	processor

Constructor Summary

Constructors

Constructor and Description
WriteResultSubscriber(AbstractListenerWriteFlushProcessor<?> processor)

Method Summary

Modifier and Type	Method and Description
void	onComplete()
void	onError(java.lang.Throwable ex)
void	onNext(java.lang.Void aVoid)
void	onSubscribe(Subscription subscription)

Methods inherited from class java.lang.Object

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

Field Detail

processor

private final AbstractListenerWriteFlushProcessor<?> processor

Constructor Detail

WriteResultSubscriber

public WriteResultSubscriber(AbstractListenerWriteFlushProcessor<?> processor)

Method Detail

onSubscribe

public void onSubscribe(Subscription subscription)

onNext

public void onNext(java.lang.Void aVoid)

onError

public void onError(java.lang.Throwable ex)

onComplete

public void onComplete()