Interface Stage.Limit

  • All Superinterfaces:
    Stage
    Enclosing interface:
    Stage

    public static interface Stage.Limit
    extends Stage
    A limit stage.

    Only limit elements may be emitted, once that many elements are emitted, downstream must be completed, and upstream must be cancelled. Any subsequent elements received from upstream before the cancellation signal is handled must be dropped.

    If less than limit elements are received before termination, then the termination must be propagated downstream as normal.

    • Method Detail

      • getLimit

        long getLimit()
        The limit.
        Returns:
        The limit.