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

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

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

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

public static interface Flow.Subscriber<T>

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

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

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

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

onSubscribe

void onSubscribe(Flow.Subscription subscription)

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

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

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

onNext

void onNext(T item)

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

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

onError

void onError(Throwable throwable)

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

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

onComplete

void onComplete()

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

© 1993, 2023, 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/21/docs/api/java.base/java/util/concurrent/Flow.Subscriber.html