Uses of Class
io.simplesource.kafka.internal.streams.AggregateTestHelper.PublishBuilder

Uses of AggregateTestHelper.PublishBuilder in io.simplesource.kafka.internal.streams

Methods in io.simplesource.kafka.internal.streams that return AggregateTestHelper.PublishBuilder

Modifier and Type	Method and Description
AggregateTestHelper.PublishBuilder	AggregateTestHelper.publishCommand(K key, io.simplesource.data.Sequence readSequence, C command)
AggregateTestHelper.PublishBuilder	AggregateTestHelper.PublishResponse.thenPublish(C command) Combinator to chain together multiple publishCommand commands.
AggregateTestHelper.PublishBuilder	AggregateTestHelper.PublishResponse.thenPublish(java.util.function.Function<AggregateUpdate<A>,ValueWithSequence<C>> commandGenerator) Combinator to chain together multiple publishCommand commands.