public class FlatMapStageVerification extends Object
Modifier and Type | Class and Description |
---|---|
class |
FlatMapStageVerification.InnerSubscriberVerification
Verifies the inner subscriber passed to publishers produced by the mapper function.
|
class |
FlatMapStageVerification.OuterProcessorVerification
Verifies the outer processor.
|
Modifier and Type | Field and Description |
---|---|
protected ReactiveStreamsFactory |
rs |
Modifier and Type | Method and Description |
---|---|
void |
flatMapStageBuilderShouldBeReusable() |
void |
flatMapStageShouldAllowEmptySubStreams() |
void |
flatMapStageShouldHandleExceptions() |
void |
flatMapStageShouldMapElements() |
void |
flatMapStageShouldOnlySubscribeToOnePublisherAtATime() |
void |
flatMapStageShouldPropagateSubstreamExceptions() |
void |
flatMapStageShouldPropagateUpstreamExceptions() |
void |
flatMapStageShouldPropgateCancelToSubstreams() |
protected final ReactiveStreamsFactory rs
public void flatMapStageShouldMapElements()
public void flatMapStageShouldAllowEmptySubStreams()
public void flatMapStageShouldHandleExceptions()
public void flatMapStageShouldPropagateUpstreamExceptions()
public void flatMapStageShouldPropagateSubstreamExceptions()
public void flatMapStageShouldOnlySubscribeToOnePublisherAtATime() throws Exception
Exception
public void flatMapStageShouldPropgateCancelToSubstreams()
public void flatMapStageBuilderShouldBeReusable()
Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.