From d15ac56146538d2bd02b369c439adc2c821046d2 Mon Sep 17 00:00:00 2001 From: Larry Safran Date: Fri, 20 Dec 2024 15:11:07 -0800 Subject: [PATCH] Switch from using jdk Predicate to the one in Guava --- stub/src/main/java/io/grpc/stub/BlockingClientCall.java | 2 +- stub/src/main/java/io/grpc/stub/ClientCalls.java | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/stub/src/main/java/io/grpc/stub/BlockingClientCall.java b/stub/src/main/java/io/grpc/stub/BlockingClientCall.java index c135f58c712..58881ef0592 100644 --- a/stub/src/main/java/io/grpc/stub/BlockingClientCall.java +++ b/stub/src/main/java/io/grpc/stub/BlockingClientCall.java @@ -18,6 +18,7 @@ import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Preconditions; +import com.google.common.base.Predicate; import io.grpc.ClientCall; import io.grpc.ExperimentalApi; import io.grpc.Metadata; @@ -28,7 +29,6 @@ import java.util.concurrent.BlockingQueue; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; -import java.util.function.Predicate; import java.util.logging.Level; import java.util.logging.Logger; diff --git a/stub/src/main/java/io/grpc/stub/ClientCalls.java b/stub/src/main/java/io/grpc/stub/ClientCalls.java index 1d83269272f..9d3ddbd1397 100644 --- a/stub/src/main/java/io/grpc/stub/ClientCalls.java +++ b/stub/src/main/java/io/grpc/stub/ClientCalls.java @@ -22,6 +22,7 @@ import com.google.common.annotations.VisibleForTesting; import com.google.common.base.MoreObjects; import com.google.common.base.Preconditions; +import com.google.common.base.Predicate; import com.google.common.base.Strings; import com.google.common.util.concurrent.AbstractFuture; import com.google.common.util.concurrent.ListenableFuture; @@ -48,7 +49,6 @@ import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.LockSupport; import java.util.concurrent.locks.ReentrantLock; -import java.util.function.Predicate; import java.util.logging.Level; import java.util.logging.Logger; import javax.annotation.Nonnull; @@ -233,9 +233,9 @@ public static BlockingClientCall blockingV2ServerStre BlockingClientCall call = blockingBidiStreamingCall(channel, method, callOptions); - call.sendSingleRequest(req); - call.halfClose(); - return call; + call.sendSingleRequest(req); + call.halfClose(); + return call; } /**