in src/main/java/com/spotify/google/cloud/pubsub/client/PubsubFuture.java [292:302]
private <U> PubsubFuture<U> wrap(final CompletableFuture<U> future) {
final PubsubFuture<U> pubsubFuture = new PubsubFuture<>(requestInfo);
future.whenComplete((v, t) -> {
if (t != null) {
pubsubFuture.fail(t);
} else {
pubsubFuture.succeed(v);
}
});
return pubsubFuture;
}