aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authoryifeizhuang <yifeizhuang@gmail.com>2023-09-12 13:41:15 -0700
committerGitHub <noreply@github.com>2023-09-12 13:41:15 -0700
commit5f480de2ee7bf56e3cb15635c0bd0d71f6f7006a (patch)
tree0457bff13acf8178e76ec647b5f3cae1e55b1850
parent923ac604162f94f906c0c7a36821671abbfd9e76 (diff)
downloadgrpc-grpc-java-5f480de2ee7bf56e3cb15635c0bd0d71f6f7006a.tar.gz
stub: enable throwing rejected execution exception on ThreadlessExecutor shutdown (#10555)
-rw-r--r--stub/src/main/java/io/grpc/stub/ClientCalls.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/stub/src/main/java/io/grpc/stub/ClientCalls.java b/stub/src/main/java/io/grpc/stub/ClientCalls.java
index 13fb00d3b..e4d675487 100644
--- a/stub/src/main/java/io/grpc/stub/ClientCalls.java
+++ b/stub/src/main/java/io/grpc/stub/ClientCalls.java
@@ -58,8 +58,8 @@ public final class ClientCalls {
@VisibleForTesting
static boolean rejectRunnableOnExecutor =
- !Strings.isNullOrEmpty(System.getenv("GRPC_CLIENT_CALL_REJECT_RUNNABLE"))
- && Boolean.parseBoolean(System.getenv("GRPC_CLIENT_CALL_REJECT_RUNNABLE"));
+ Strings.isNullOrEmpty(System.getenv("GRPC_CLIENT_CALL_REJECT_RUNNABLE"))
+ || Boolean.parseBoolean(System.getenv("GRPC_CLIENT_CALL_REJECT_RUNNABLE"));
// Prevent instantiation
private ClientCalls() {}