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

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

public static interface Flow.Subscription

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

С:: 9

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

Модификатор и тип	Метод	Описание
`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, 2025, 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://download.java.net/java/early_access/jdk24/docs/api/java.base/java/util/concurrent/Flow.Subscription.html