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

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.

From interface


        
          java.util.concurrent.Flow.Publisher


      subscribe(Subscriber<? super T> subscriber)

Adds the given Subscriber if possible.