Интерфейс Flow.Processor<T,R>

Параметры типа:: T - тип подписываемого элемента; R - тип публикуемого элемента

Все суперинтерфейсы:: Flow.Publisher<R>, Flow.Subscriber<T>

Внешний класс:: Flow

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

Компонент, выступающий одновременно в роли подписчика и издателя.

Начиная с:: 9

Краткое описание методов

Методы, объявленные в интерфейсе Flow.Publisher

subscribe

Модификатор и тип	Метод	Описание
`void`	`subscribe(Flow.Subscriber<? super R> subscriber)`	Добавляет указанного подписчика, если это возможно.

Методы, объявленные в интерфейсе Flow.Subscriber

onComplete, onError, onNext, onSubscribe

Модификатор и тип	Метод	Описание
`void`	`onComplete()`	Метод вызывается, когда становится известно, что для подписки больше не будет вызовов других методов подписчика, если она не была ранее завершена из-за ошибки; после этого подписка не вызывает другие методы подписчика.
`void`	`onError(Throwable throwable)`	Метод вызывается при возникновении неисправимой ошибки у издателя или подписки; после этого подписка не вызывает другие методы подписчика.
`void`	`onNext(T item)`	Метод вызывается со следующим элементом подписки.
`void`	`onSubscribe(Flow.Subscription 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.