public class ProcessorBuilderVerification extends AbstractReactiveStreamsApiVerification
ProcessorBuilder
class.rs
Constructor and Description |
---|
ProcessorBuilderVerification(ReactiveStreamsFactory rs) |
assertEmptyStage, graphFor, graphFor, graphFor, graphFor
public ProcessorBuilderVerification(ReactiveStreamsFactory rs)
public void map()
public void mapNullFunction()
public void peek()
public void peekNullConsumer()
public void filter()
public void filterNullPredicate()
public void distinct()
public void flatMap()
public void flatMapToBuilderFromDifferentReactiveStreamsImplementation()
public void flatMapNullMapper()
public void flatMapRsPublisher()
public void flatMapRsPublisherNullMapper()
public void flatMapCompletionStageNullMapper()
public void flatMapIterable()
public void flatMapIterableNullMapper()
public void limit()
public void limitNegative()
public void skip()
public void skipNegative()
public void takeWhile()
public void takeWhileNullPredicate()
public void dropWhile()
public void dropWhileNullPredicate()
public void forEach()
public void forEachNullConsumer()
public void ignore()
public void cancel()
public void reduceWithIdentity()
public void reduceWithIdentityNullIdentityAllowed()
public void reduceWithIdentityNullAccumulator()
public void reduce()
public void reduceNullAccumulator()
public void findFirst()
public void collect()
public void collectNull()
public void collectComponents()
public void collectComponentsSupplierNull()
public void collectComponentsAccumulatorNull()
public void toList()
public void toSubscriber()
public void toSubscriberNull()
public void to()
public void toBuilderFromDifferentReactiveStreamsImplementation()
public void toMultipleStages()
public void toNull()
public void viaProcessor()
public void viaProcessorNull()
public void via()
public void viaBuilderFromDifferentReactiveStreamsImplementation()
public void viaEmpty()
public void viaMultipleStages()
public void viaNull()
public void onError()
public void onErrorNullConsumer()
public void onErrorResume()
public void onErrorResumeNull()
public void onErrorResumeWith()
public void onErrorResumeWithToBuilderFromDifferentReactiveStreamsImplementation()
public void onErrorResumeWithNull()
public void onErrorResumeWithRsPublisher()
public void onErrorResumeWithRsPublisherNull()
public void onTerminate()
public void onTerminateNull()
public void onComplete()
public void onCompleteNull()
public void buildRs()
public void buildRsNull()
public void builderShouldBeImmutable()
Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.