HIGUCHI Yuta

Workaround for Eclipse

- Current Eclipse compiler fails to infer appropriate
  generic type.
  Workaround the issue by explicitly specifying the type.

  Might be related to:
   https://bugs.eclipse.org/bugs/show_bug.cgi?id=467561

Change-Id: I7f41fd1a33f165fa8a57120a6f9a42cf587f94cc
......@@ -91,7 +91,7 @@ public class DefaultDistributedQueue<E> implements DistributedQueue<E> {
.whenComplete((r, e) -> timer.stop(e))
.thenCompose(v -> {
if (v != null) {
return CompletableFuture.completedFuture(serializer.decode(v));
return CompletableFuture.<E>completedFuture(serializer.decode(v));
}
CompletableFuture<E> newPendingFuture = new CompletableFuture<>();
pendingFutures.add(newPendingFuture);
......