reactor.core.publisher

Interface SynchronousSink<T>

Type Parameters:

T - the output value type

public interface SynchronousSink<T>

Interface to generate signals to a bridged Subscriber.

At most one next(T) call and/or one complete() or error(Throwable) should be called per invocation of the generator function

Method Summary

Modifier and Type	Method and Description
void	complete()
void	error(java.lang.Throwable e)
void	next(T t) Try emitting, might throw an unchecked exception.

Method Detail

complete

void complete()

See Also:

Subscriber.onComplete()

error

void error(java.lang.Throwable e)

Parameters:

e - the exception to signal, not null

See Also:

Subscriber.onError(Throwable)

next

void next(T t)

Try emitting, might throw an unchecked exception.

Parameters:

t - the value to emit, not null

Throws:

java.lang.RuntimeException - in case of unchecked error during the emission

See Also:

Subscriber.onNext(Object)