Flow.Processor

public static interface Flow.Processor
implements Publisher, Subscriber

java.util.concurrent.Flow.Processor

A component that acts as both a Subscriber and Publisher.

Summary

From interface


        
          java.util.concurrent.Flow.Publisher


      subscribe(Subscriber subscriber)

Adds the given Subscriber if possible.

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.