Added in API level 30

Flow.Processor

public static interface Flow.Processor
implements Publisher<R>, Subscriber<T>

java.util.concurrent.Flow.Processor<T, R>


A component that acts as both a Subscriber and Publisher.

Summary

Inherited methods

abstract void subscribe(Subscriber<? super T> subscriber)

Adds the given Subscriber if possible.

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.