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>
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.
ConsumerEx<? super S> completeFn)(Sets the function that will be called after all the upstream stages have completed and all the items were received.
BiConsumerEx<? super S,? super T_NEW> receiveFn)(Sets the function Jet will call upon receiving every item.
ConsumerEx<? super S> timerFn)(Sets the function that will be called periodically.