インタフェースFlow.Processor<T,R>

型パラメータ:
T - サブスクライブされたアイテム型
R - 公開アイテム型
すべてのスーパー・インタフェース:
Flow.Publisher<R>, Flow.Subscriber<T>
含まれているクラス:
Flow
public static interface Flow.Processor<T,R> extends Flow.Subscriber<T>, Flow.Publisher<R>
サブスクライバとパブリッシャの両方として機能するコンポーネント。
導入されたバージョン:
9

  • メソッドのサマリー

    インタフェースで宣言されたメソッド Flow.Publisher

    subscribe
    修飾子と型
    メソッド
    説明
    void
    subscribe(Flow.Subscriber<? super R> subscriber)
    可能な場合は、指定されたサブスクライバを追加します。

    インタフェースで宣言されたメソッド Flow.Subscriber

    onComplete, onError, onNext, onSubscribe
    修飾子と型
    メソッド
    説明
    void
    onComplete()
    まだエラーによって終了されていないサブスクリプションに対して追加のサブスクライバ・メソッド呼出しが発生しないことがわかっている場合に呼び出されるメソッド。その後、サブスクリプションによって他のサブスクライバ・メソッドが呼び出されることはありません。
    void
    onError(Throwable throwable)
    パブリッシャまたはサブスクリプションで発生したリカバリ不能なエラー時に呼び出されるメソッド。その後、サブスクリプションによって他のサブスクライバ・メソッドが呼び出されません。
    void
    onNext(T item)
    サブスクリプションの次のアイテムで呼び出されるメソッド。
    void
    onSubscribe(Flow.Subscription subscription)
    指定されたサブスクリプションに対して他のサブスクライバ・メソッドを呼び出す前に呼び出されるメソッド。