A C E I P Q T
All Classes All Packages

A

AggregateTestDriver<K,C,E,A> - Class in io.simplesource.kafka.testutils

AggregateTestDriver(AggregateSpec<K, C, E, A>, KafkaConfig) - Constructor for class io.simplesource.kafka.testutils.AggregateTestDriver

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

AggregateTestHelper(AggregateTestDriver<K, C, E, A>) - Constructor for class io.simplesource.kafka.testutils.AggregateTestHelper

AggregateTestHelper.PublishBuilder - Class in io.simplesource.kafka.testutils

AggregateTestHelper.PublishResponse - Class in io.simplesource.kafka.testutils

C

close() - Method in class io.simplesource.kafka.testutils.AggregateTestDriver

E

expecting(NonEmptyList<E>, A) - Method in class io.simplesource.kafka.testutils.AggregateTestHelper.PublishBuilder

Publish the command and assert that the publishCommand was success generating the given events and aggregate_update update.

expectingFailure(NonEmptyList<CommandError.Reason>) - Method in class io.simplesource.kafka.testutils.AggregateTestHelper.PublishBuilder

Publish the command and assert that the call failed.

expectingFailure(Consumer<NonEmptyList<CommandError>>) - Method in class io.simplesource.kafka.testutils.AggregateTestHelper.PublishBuilder

Publish the command and assert that the call failed.

I

io.simplesource.kafka.testutils - package io.simplesource.kafka.testutils

P

pollForApiResponse() - Method in class io.simplesource.kafka.testutils.AggregateTestDriver

publishCommand(CommandAPI.Request<K, C>) - Method in class io.simplesource.kafka.testutils.AggregateTestDriver

publishCommand(K, Sequence, C) - Method in class io.simplesource.kafka.testutils.AggregateTestHelper

Q

queryCommandResult(CommandId, Duration) - Method in class io.simplesource.kafka.testutils.AggregateTestDriver

T

thenPublish(C) - Method in class io.simplesource.kafka.testutils.AggregateTestHelper.PublishResponse

Combinator to chain together multiple publishCommand commands.

thenPublish(Function<AggregateUpdate<A>, ValueWithSequence<C>>) - Method in class io.simplesource.kafka.testutils.AggregateTestHelper.PublishResponse

Combinator to chain together multiple publishCommand commands.

A C E I P Q T
All Classes All Packages