Package io.helidon.common.reactive
Interface Flow.Subscription
-
- Enclosing class:
- Flow
public static interface Flow.Subscription
Message control linking aFlow.Publisher
andFlow.Subscriber
. Subscribers receive items only when requested, and may cancel at any time. The methods in this interface are intended to be invoked only by their Subscribers; usages in other contexts have undefined effects.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
cancel()
Causes the Subscriber to (eventually) stop receiving messages.void
request(long n)
Adds the given numbern
of items to the current unfulfilled demand for this subscription.
-
-
-
Method Detail
-
request
void request(long n)
Adds the given numbern
of items to the current unfulfilled demand for this subscription. Ifn
is less than or equal to zero, the Subscriber will receive anonError
signal with anIllegalArgumentException
argument. Otherwise, the Subscriber will receive up ton
additionalonNext
invocations (or fewer if terminated).- Parameters:
n
- the increment of demand; a value ofLong.MAX_VALUE
may be considered as effectively unbounded
-
cancel
void cancel()
Causes the Subscriber to (eventually) stop receiving messages. Implementation is best-effort -- additional messages may be received after invoking this method. A cancelled subscription need not ever receive anonComplete
oronError
signal.
-
-