Uses of Class com.hazelcast.jet.pipeline.test.AssertionSinkBuilder (hazelcast-jet-distribution 4.3 API)

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	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.