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