Интерфейс 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.

© 1993, 2021, 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/17/docs/api/java.base/java/util/concurrent/Flow.Subscription.html