Uses of Class
This package contains various mock sources to help with pipeline testing and development.
Methods in com.hazelcast.jet.pipeline.test that return AssertionSinkBuilder Modifier and Type Method Description
static <S> AssertionSinkBuilder<S,Void>
assertionSink(String name, SupplierEx<? extends S> createFn)Returns a builder object that offers a step-by-step fluent API to build an assertion
Sinkfor the Pipeline API.
completeFn(ConsumerEx<? super S> completeFn)Sets the function that will be called after all the upstream stages have completed and all the items were received.
receiveFn(BiConsumerEx<? super S,? super T_NEW> receiveFn)Sets the function Jet will call upon receiving every item.
timerFn(ConsumerEx<? super S> timerFn)Sets the function that will be called periodically.