Uses of Class
com.hazelcast.jet.pipeline.test.AssertionSinkBuilder

Packages that use AssertionSinkBuilder

Package	Description
com.hazelcast.jet.pipeline.test	This package contains various mock sources to help with pipeline testing and development.

Uses of AssertionSinkBuilder in com.hazelcast.jet.pipeline.test

Methods in com.hazelcast.jet.pipeline.test that return AssertionSinkBuilder

Modifier and Type	Method and Description
static <S> AssertionSinkBuilder<S,Void>	AssertionSinkBuilder.assertionSink(String name, SupplierEx<? extends S> createFn) Returns a builder object that offers a step-by-step fluent API to build an assertion Sink for the Pipeline API.
AssertionSinkBuilder<S,T>	AssertionSinkBuilder.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.
<T_NEW> AssertionSinkBuilder<S,T_NEW>	AssertionSinkBuilder.receiveFn(BiConsumerEx<? super S,? super T_NEW> receiveFn) Sets the function Jet will call upon receiving every item.
AssertionSinkBuilder<S,T>	AssertionSinkBuilder.timerFn(ConsumerEx<? super S> timerFn) Sets the function that will be called periodically.