Package io.simplesource.kafka.testutils

Class AggregateTestHelper<K,C,E,A>

java.lang.Object

io.simplesource.kafka.testutils.AggregateTestHelper<K,C,E,A>

public final class AggregateTestHelper<K,C,E,A>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	AggregateTestHelper.PublishBuilder
class	AggregateTestHelper.PublishResponse

Constructor Summary

Constructors

Constructor	Description
AggregateTestHelper(AggregateTestDriver<K,C,E,A> testAPI)

Method Summary

Modifier and Type	Method	Description
AggregateTestHelper.PublishBuilder	publishCommand(K key, io.simplesource.data.Sequence readSequence, C command)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregateTestHelper

public AggregateTestHelper(AggregateTestDriver<K,C,E,A> testAPI)

Method Detail

publishCommand

public AggregateTestHelper.PublishBuilder publishCommand(K key,
                                                         io.simplesource.data.Sequence readSequence,
                                                         C command)