Интерфейс Flow.Subscriber<T>

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

Все известные подинтерфейсы:: Flow.Processor<T,R>, HttpResponse.BodySubscriber<T>

Включающий класс:: Flow

public static interface Flow.Subscriber<T>

Получатель сообщений. Методы этого интерфейса вызываются в строгом последовательном порядке для каждой Flow.Subscription.

Начиная с версии:: 9

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

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

Подробное описание методов

onSubscribe

void onSubscribe(Flow.Subscription subscription)

Метод вызывается перед вызовом любых других методов подписчика для данной подписки. Если этот метод выбрасывает исключение, поведение не гарантируется, однако подписка может не быть установлена или может быть отменена.

Обычно реализации этого метода вызывают subscription.request, чтобы начать получать элементы.

Параметры:: subscription - новая подписка

onNext

void onNext(T item)

Метод вызывается при получении следующего элемента подписки. Если этот метод выбрасывает исключение, поведение не гарантируется, однако подписка может быть отменена.

Параметры:: item - элемент

onError

void onError(Throwable throwable)

Метод вызывается при возникновении невосстановимой ошибки у издателя или подписки; после этого подписка больше не вызывает никаких методов подписчика. Если сам этот метод выбрасывает исключение, поведение не определено.

Параметры:: throwable - исключение

onComplete

void onComplete()

Метод вызывается, когда становится известно, что для подписки, которая ещё не была завершена ошибкой, больше не будет вызовов методов подписчика; после этого подписка больше не вызывает никаких методов подписчика. Если этот метод выбрасывает исключение, поведение не определено.

© 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.
https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Subscriber.html