Skip to content

Commit 8180397

Browse files
committed
Check success in batch handler (issue #5)
1 parent 91be26e commit 8180397

File tree

1 file changed

+11
-9
lines changed

1 file changed

+11
-9
lines changed

src/main/java/io/engagingspaces/vertx/dataloader/DataLoader.java

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -138,16 +138,18 @@ public CompositeFuture dispatch() {
138138
return CompositeFuture.all(Collections.emptyList());
139139
}
140140
CompositeFuture batch = batchLoadFunction.load(loaderQueue.keySet());
141-
AtomicInteger index = new AtomicInteger(0);
142-
loaderQueue.forEach((key, future) -> {
143-
if (batch.succeeded(index.get())) {
144-
future.complete(batch.resultAt(index.get()));
145-
} else {
146-
future.fail(batch.cause(index.get()));
147-
}
148-
index.incrementAndGet();
141+
batch.setHandler(rh -> {
142+
AtomicInteger index = new AtomicInteger(0);
143+
loaderQueue.forEach((key, future) -> {
144+
if (batch.succeeded(index.get())) {
145+
future.complete(batch.resultAt(index.get()));
146+
} else {
147+
future.fail(batch.cause(index.get()));
148+
}
149+
index.incrementAndGet();
150+
});
151+
loaderQueue.clear();
149152
});
150-
loaderQueue.clear();
151153
return batch;
152154
}
153155

0 commit comments

Comments
 (0)