Интерфейс 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://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Subscription.html