Flow.Processor
public
static
interface
Flow.Processor
implements
Subscriber<T>,
Publisher<R>
| java.util.concurrent.Flow.Processor<T, R>
|
A component that acts as both a Subscriber and Publisher.
Summary
Inherited methods |
|---|
From interface
java.util.concurrent.Flow.Subscriber
abstract
void
|
onComplete()
Method invoked when it is known that no additional
Subscriber method invocations will occur for a Subscription
that is not already terminated by error, after which no
other Subscriber methods are invoked by the Subscription.
|
abstract
void
|
onError(Throwable throwable)
Method invoked upon an unrecoverable error encountered by a
Publisher or Subscription, after which no other Subscriber
methods are invoked by the Subscription.
|
abstract
void
|
onNext(T item)
Method invoked with a Subscription's next item.
|
abstract
void
|
onSubscribe(Flow.Subscription subscription)
Method invoked prior to invoking any other Subscriber
methods for the given Subscription.
|
|
|
|
