fix a RejectedExecutionException
@@ -179,8 +179,10 @@ final class ClientConnectionManager {
}
}
+ if (builder.executorService() == null) {
executorService.shutdownNow();
}
+ }
<T extends AbstractStub<T>, R> CompletableFuture<R> withNewChannel(URI endpoint, Function<ManagedChannel, T> stubCustomizer,
Function<T, CompletableFuture<R>> stubConsumer) {
