File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed
main/java/io/engagingspaces/vertx/dataloader
test/java/io/engagingspaces/vertx/dataloader Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -100,7 +100,7 @@ public Future<V> load(K key) {
100
100
} else {
101
101
CompositeFuture compositeFuture = batchLoadFunction .load (Collections .singleton (key ));
102
102
if (compositeFuture .succeeded ()) {
103
- future .complete (compositeFuture .result ().result (0 ));
103
+ future .complete (compositeFuture .result ().resultAt (0 ));
104
104
} else {
105
105
future .fail (compositeFuture .cause ());
106
106
}
@@ -141,7 +141,7 @@ public CompositeFuture dispatch() {
141
141
AtomicInteger index = new AtomicInteger (0 );
142
142
loaderQueue .forEach ((key , future ) -> {
143
143
if (batch .succeeded (index .get ())) {
144
- future .complete (batch .result (index .get ()));
144
+ future .complete (batch .resultAt (index .get ()));
145
145
} else {
146
146
future .fail (batch .cause (index .get ()));
147
147
}
Original file line number Diff line number Diff line change @@ -445,8 +445,8 @@ public void should_Accept_objects_as_keys() {
445
445
446
446
identityLoader .dispatch ().setHandler (rh -> {
447
447
assertThat (rh .succeeded (), is (true ));
448
- assertThat (rh .result ().result (0 ), equalTo (keyA ));
449
- assertThat (rh .result ().result (1 ), equalTo (keyB ));
448
+ assertThat (rh .result ().resultAt (0 ), equalTo (keyA ));
449
+ assertThat (rh .result ().resultAt (1 ), equalTo (keyB ));
450
450
});
451
451
452
452
assertThat (loadCalls .size (), equalTo (1 ));
@@ -464,7 +464,7 @@ public void should_Accept_objects_as_keys() {
464
464
465
465
identityLoader .dispatch ().setHandler (rh -> {
466
466
assertThat (rh .succeeded (), is (true ));
467
- assertThat (rh .result ().result (0 ), equalTo (keyA ));
467
+ assertThat (rh .result ().resultAt (0 ), equalTo (keyA ));
468
468
assertThat (identityLoader .getCacheKey (keyB ), equalTo (keyB ));
469
469
});
470
470
You can’t perform that action at this time.
0 commit comments