# Flow.Processor

public static interface **Flow.Processor** implements [Subscriber](https://developers.google.com/j2objc/javadoc/jre/reference/java/util/concurrent/Flow.Subscriber.html)\<T\> [Publisher](https://developers.google.com/j2objc/javadoc/jre/reference/java/util/concurrent/Flow.Publisher.html)\<R\> A component that acts as both a Subscriber and Publisher.

### Inherited Method Summary

From interface [java.util.concurrent.Flow.Subscriber](https://developers.google.com/j2objc/javadoc/jre/reference/java/util/concurrent/Flow.Subscriber.html)

|---|---|
| abstract void | [onComplete](https://developers.google.com/j2objc/javadoc/jre/reference/java/util/concurrent/Flow.Subscriber.html#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](https://developers.google.com/j2objc/javadoc/jre/reference/java/util/concurrent/Flow.Subscriber.html#onError(java.lang.Throwable))([Throwable](https://developers.google.com/j2objc/javadoc/jre/reference/java/lang/Throwable.html) 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](https://developers.google.com/j2objc/javadoc/jre/reference/java/util/concurrent/Flow.Subscriber.html#onNext(T))(T item) Method invoked with a Subscription's next item. |
| abstract void | [onSubscribe](https://developers.google.com/j2objc/javadoc/jre/reference/java/util/concurrent/Flow.Subscriber.html#onSubscribe(java.util.concurrent.Flow.Subscription))([Flow.Subscription](https://developers.google.com/j2objc/javadoc/jre/reference/java/util/concurrent/Flow.Subscription.html) subscription) Method invoked prior to invoking any other Subscriber methods for the given Subscription. |

From interface [java.util.concurrent.Flow.Publisher](https://developers.google.com/j2objc/javadoc/jre/reference/java/util/concurrent/Flow.Publisher.html)

|---|---|
| abstract void | [subscribe](https://developers.google.com/j2objc/javadoc/jre/reference/java/util/concurrent/Flow.Publisher.html#subscribe(java.util.concurrent.Flow.Subscriber<?%20super%20T>))([Subscriber](https://developers.google.com/j2objc/javadoc/jre/reference/java/util/concurrent/Flow.Subscriber.html)\<? super T\> subscriber) Adds the given Subscriber if possible. |