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

Методы

onSubscribe(java.util.concurrent.Flow.Subscription)

void onSubscribe(Flow.Subscription subscription)

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

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

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

onNext(java.lang.Object)

void onNext(T item)

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

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

onError(java.lang.Throwable)

void onError(Throwable throwable)

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

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

onComplete()

void onComplete()

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