Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<AggregateUpdate<A>> |
AggregateSerdes.aggregateUpdate() |
Modifier and Type | Method and Description |
---|---|
<S> AggregateUpdate<S> |
AggregateUpdate.map(java.util.function.Function<A,S> f) |
static <A> AggregateUpdate<A> |
AggregateUpdate.of(A a) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<AggregateUpdate<A>> |
AvroAggregateSerdes.aggregateUpdate() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<AggregateUpdate<A>> |
JsonAggregateSerdes.aggregateUpdate() |
Modifier and Type | Method and Description |
---|---|
AggregateTestHelper.PublishBuilder |
AggregateTestHelper.PublishResponse.thenPublish(java.util.function.Function<AggregateUpdate<A>,ValueWithSequence<C>> commandGenerator)
Combinator to chain together multiple publishCommand commands.
|
Copyright © 2019. All rights reserved.