Interface Flow.Processor<T,R>

Type Parameters:: T - the subscribed item type; R - the published item type

All Superinterfaces:: Flow.Publisher<R>, Flow.Subscriber<T>

Enclosing class:: Flow

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

A component that acts as both a Subscriber and Publisher.

Since:: 9

Method Summary

Methods declared in interface Flow.Publisher

subscribe

Modifier and Type	Method	Description
`void`	`subscribe(Flow.Subscriber<? super R> subscriber)`	Adds the given Subscriber if possible.

Methods declared in interface Flow.Subscriber

onComplete, onError, onNext, onSubscribe

Modifier and Type	Method	Description
`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.
`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.
`void`	`onNext(T item)`	Method invoked with a Subscription's next item.
`void`	`onSubscribe(Flow.Subscription subscription)`	Method invoked prior to invoking any other Subscriber methods for the given Subscription.

© 1993, 2025, Oracle and/or its affiliates. All rights reserved.
Documentation extracted from Debian's OpenJDK Development Kit package.
Licensed under the GNU General Public License, version 2, with the Classpath Exception.
Various third party code in OpenJDK is licensed under different licenses (see Debian package).
Java and OpenJDK are trademarks or registered trademarks of Oracle and/or its affiliates.