Интерфейс Flow.Subscription

Вложенный класс:: Flow

public static interface Flow.Subscription

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

Методы

Модификатор и тип	Метод	Описание
`void`	`cancel()`	Приводит к тому, что подписчик (в конечном итоге) перестаёт получать сообщения.
`void`	`request(long n)`	Добавляет указанное количество `n` элементов к текущей незавершенной потребности для этой подписки.

Методы

request

void request(long n)

Добавляет указанное количество n элементов к текущей незавершенной потребности для этой подписки. Если n меньше или равно нулю, подписчик получит сигнал onError с аргументом IllegalArgumentException. В противном случае подписчик получит до n дополнительных onNext вызовов (или меньше, если завершён).

Параметры:: n - приращение спроса; значение Long.MAX_VALUE может рассматриваться как фактически неограниченное

cancel

void cancel()

Приводит к тому, что подписчик (в конечном итоге) перестаёт получать сообщения. Реализация выполняется с наименьшими усилиями — дополнительные сообщения могут быть получены после вызова этого метода. Отменённая подписка может никогда не получить сигнал onComplete или onError.