private CompletableFuture createFuture()

in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/PulsarFutureAdapter.java [79:92]

• 14 lines of code
• 2 McCabe index (conditional complexity)

	private <T> CompletableFuture<T> createFuture(Supplier<? extends CompletableFuture<T>> futureSupplier) {
		try {
			CompletableFuture<T> future = futureSupplier.get();
			this.futureReference = future;
			return future.exceptionally((ex) -> {
				handleException(this.cancelled, ex);
				return null;
			});
		}
		catch (Exception ex) {
			handleException(this.cancelled, ex);
			return CompletableFuture.completedFuture(null);
		}
	}