reactor.core.publisher

Interface FluxSink<T>

Type Parameters:

T - the value type

public interface FluxSink<T>

Wrapper API around a downstream Subscriber for emitting any number of next signals followed by zero or one onError/onComplete.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	FluxSink.OverflowStrategy Enumeration for backpressure handling.

Method Summary

Modifier and Type	Method and Description
void	complete()
void	fail(java.lang.Throwable e)
void	next(T t) Try emitting, might throw an unchecked exception.
void	setCancellation(Cancellation c) Associate a cancellation-based resource with this FluxSink that will be disposed in case the downstream cancels the sequence via Subscription.cancel().

Method Detail

complete

void complete()

See Also:

Subscriber.onComplete()

fail

void fail(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

See Also:

Subscriber.onNext(Object)

setCancellation

void setCancellation(Cancellation c)

Associate a cancellation-based resource with this FluxSink that will be disposed in case the downstream cancels the sequence via Subscription.cancel().

Parameters:

c -