public class LimitStageVerification extends Object
Modifier and Type | Class and Description |
---|---|
class |
LimitStageVerification.ProcessorVerification |
Modifier and Type | Field and Description |
---|---|
protected ReactiveStreamsFactory |
rs |
Modifier and Type | Method and Description |
---|---|
void |
limitStageBuilderShouldBeReusable() |
void |
limitStageShouldAllowLimitingToZero() |
void |
limitStageShouldCancelUpStreamWhenDone() |
void |
limitStageShouldIgnoreSubsequentErrorsWhenDone() |
void |
limitStageShouldLimitTheOutputElements() |
void |
limitStageShouldPropagateCancellation() |
void |
limitStageToZeroShouldCompleteStreamEvenWhenNoElementsAreReceived() |
protected final ReactiveStreamsFactory rs
public void limitStageShouldLimitTheOutputElements()
public void limitStageShouldAllowLimitingToZero()
public void limitStageToZeroShouldCompleteStreamEvenWhenNoElementsAreReceived()
public void limitStageShouldCancelUpStreamWhenDone()
public void limitStageShouldIgnoreSubsequentErrorsWhenDone()
public void limitStageShouldPropagateCancellation()
public void limitStageBuilderShouldBeReusable()
Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.