Package io.simplesource.kafka.testutils

Class AggregateTestHelper.PublishResponse

java.lang.Object

io.simplesource.kafka.testutils.AggregateTestHelper.PublishResponse

Enclosing class:

AggregateTestHelper<K,C,E,A>

public final class AggregateTestHelper.PublishResponse
extends Object

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

thenPublish

public AggregateTestHelper.PublishBuilder thenPublish(C command)

Combinator to chain together multiple publishCommand commands. Uses sequence from most recent event.

Parameters:

command - the next command to publishCommand

thenPublish

public AggregateTestHelper.PublishBuilder thenPublish(java.util.function.Function<io.simplesource.kafka.model.AggregateUpdate<A>,io.simplesource.kafka.model.ValueWithSequence<C>> commandGenerator)

Combinator to chain together multiple publishCommand commands. Use this version if you need access to the current project, or if you want to mess with the sequence.

Parameters:

commandGenerator - a generate a new command and sequence from the latest project value and sequence