io.simplesource.kafka.internal.streams

Class AggregateTestHelper<K,C,E,A>

java.lang.Object

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

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

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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)