private FutureUtils.ConjunctFuture<Void> closeHandlersAsync() {
	return FutureUtils.waitForAll(handlers.stream()
		.map(tuple -> tuple.f1)
		.filter(handler -> handler instanceof AutoCloseableAsync)
		.map(handler -> ((AutoCloseableAsync) handler).closeAsync())
		.collect(Collectors.toList()));
}
 

private FutureUtils.ConjunctFuture<Void> closeHandlersAsync() {
	return FutureUtils.waitForAll(handlers.stream()
		.map(tuple -> tuple.f1)
		.filter(handler -> handler instanceof AutoCloseableAsync)
		.map(handler -> ((AutoCloseableAsync) handler).closeAsync())
		.collect(Collectors.toList()));
}
 

/**
 * Shuts the given rpc services down and waits for their termination.
 *
 * @param rpcServices to shut down
 * @param timeout for this operation
 * @throws InterruptedException if the operation has been interrupted
 * @throws ExecutionException if a problem occurred
 * @throws TimeoutException if a timeout occurred
 */
public static void terminateRpcServices(
		Time timeout,
		RpcService... rpcServices) throws InterruptedException, ExecutionException, TimeoutException {
	terminateAsyncCloseables(
		Arrays.stream(rpcServices)
			.map(rpcService -> (AutoCloseableAsync) rpcService::stopService)
			.collect(Collectors.toList()),
		timeout);
}
 

private static void terminateAsyncCloseables(Collection<? extends AutoCloseableAsync> closeables, Time timeout) throws InterruptedException, ExecutionException, TimeoutException {
	final Collection<CompletableFuture<?>> terminationFutures = new ArrayList<>(closeables.size());

	for (AutoCloseableAsync closeableAsync : closeables) {
		if (closeableAsync != null) {
			terminationFutures.add(closeableAsync.closeAsync());
		}
	}

	FutureUtils.waitForAll(terminationFutures).get(timeout.toMilliseconds(), TimeUnit.MILLISECONDS);
}
 

private FutureUtils.ConjunctFuture<Void> closeHandlersAsync() {
	return FutureUtils.waitForAll(handlers.stream()
		.map(tuple -> tuple.f1)
		.filter(handler -> handler instanceof AutoCloseableAsync)
		.map(handler -> ((AutoCloseableAsync) handler).closeAsync())
		.collect(Collectors.toList()));
}