JarCasting
domino-aggregate
provides a declarative way to wait for a set of events to be completed before executing some code.
This might be implemented later using Rx or Futures.
Maven dependencies
-
Release
-
Api
<dependency> <groupId>org.dominokit</groupId> <artifactId>domino-aggregator-shared</artifactId> <version>1.0.0</version> </dependency>
-
Annotation processor
<dependency> <groupId>org.dominokit</groupId> <artifactId>domino-aggregator-apt</artifactId> <version>1.0.0</version> <scope>provided</scope> </dependency>
-
-
Development snapshot
-
Api
<dependency> <groupId>org.dominokit</groupId> <artifactId>domino-aggregator-shared</artifactId> <version>HEAD-SNAPSHOT</version> </dependency>
-
Annotation processor
<dependency> <groupId>org.dominokit</groupId> <artifactId>domino-aggregator-apt</artifactId> <version>HEAD-SNAPSHOT</version> <scope>provided</scope> </dependency>
-
Usage
- Basic
ContextAggregator.ContextWait<String> waitForString = ContextAggregator.ContextWait.create();
ContextAggregator.ContextWait<Integer> waitForInteger = ContextAggregator.ContextWait.create();
ContextAggregator.waitFor(waitForString, waitForInteger)
.onReady(() -> {
//will be called when both waits are resolved.
});
waitForString.complete("some string");
waitForInteger.complete(5);
- Declarative
1 - iIn a class define a method and annotate it as @Aggregate specifying a desired class name, and the method parameters represent the events to be received.
public class App{
@Aggregate(name = "EventsAggregate")
public void onAllEventCompleted(String event1, Long event2){
//will be called when both waits are resolved.
}
}
2 - Define a field of the aggregate class, which should be generated for you
private EventsAggregate eventsAggregate = new EventsAggregate();
3 - Init the aggregate with an instance of the target class from which the method will be called.
eventsAggregate.init(appInstance);
4- Complete the events to invoke the target method
eventsAggregate.completeEvent1("some string");
eventsAggregate.completeEvent2(5);
Full sample
public class AggregateTest {
private EventsAggregate eventsAggregate = new EventsAggregate();
public void AggregateTest(){
eventsAggregate.init(this);
}
@Aggregate(name = "EventsAggregate")
public void onAllEventCompleted(String event1, Long event2){
//this will be called when both events are completed.
}
//In some other parts you complete the events, something like in a success of failed rest call.
public void shouldCallAggregateMethod(){
eventsAggregate.completeEvent1("some String");
eventsAggregate.completeEvent2(5L);
}
}
