モジュール java.base

パッケージ java.util.concurrent

インタフェースFlow.Subscription

含まれているクラス:

Flow

public static interface Flow.Subscription

Flow.PublisherとFlow.Subscriberをリンクするメッセージ制御。 サブスクライバは、リクエストされた場合にのみアイテムを受信し、いつでも取り消すことができます。 このインタフェースのメソッドは、サブスクライバによってのみ起動されます。他のコンテキストでの使用には、未定義の効果があります。

メソッドのサマリー

修飾子と型	メソッド	説明
void	cancel()	サブスクライバが(eventually)になり、メッセージの受信が停止します。
void	request(long n)	指定された数のアイテムnを、このサブスクリプションの現在の未履行需要に追加します。

メソッドの詳細

request

void request(long n)

指定された数のアイテムnを、このサブスクリプションの現在の未履行需要に追加します。 nがゼロ以下の場合、サブスクライバはIllegalArgumentException引数を持つonErrorシグナルを受信します。 それ以外の場合、サブスクライバは最大nの追加の onNext呼出し(終了した場合はそれ以下)を受け取ります。

パラメータ:

n - 需要の増加。 Long.MAX_VALUEの値は実質的に無制限と見なすことができます

cancel

void cancel()

サブスクライバが(eventually)になり、メッセージの受信が停止します。 実装はベスト・エフォートです -- このメソッドを呼び出すと、追加のメッセージを受信できます。 取り消されたサブスクリプションは、onCompleteまたはonErrorシグナルを受信する必要はありません。