Merge branch 'main' into grpc-web-it

eclipse-vertx · Feb 5, 2025 · 38d88b1 · 38d88b1
2 parents 7a4921a + a4f8e07
commit 38d88b1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/vertx-grpc-common/src/main/java/io/vertx/grpc/common/impl/GrpcReadStreamBase.java b/vertx-grpc-common/src/main/java/io/vertx/grpc/common/impl/GrpcReadStreamBase.java
@@ -18,7 +18,7 @@
 import io.vertx.core.buffer.Buffer;
 import io.vertx.core.http.StreamResetException;
 import io.vertx.core.internal.ContextInternal;
-import io.vertx.core.internal.concurrent.InboundMessageQueue;
+import io.vertx.core.internal.concurrent.InboundMessageChannel;
 import io.vertx.core.streams.ReadStream;
 import io.vertx.grpc.common.*;
 
@@ -53,7 +53,7 @@ public Buffer payload() {
   private final long maxMessageSize;
   private final WireFormat format;
   private final ReadStream<Buffer> stream;
-  private final InboundMessageQueue<GrpcMessage> queue;
+  private final InboundMessageChannel<GrpcMessage> queue;
   private Buffer buffer;
   private long bytesToSkip;
   private Handler<Throwable> exceptionHandler;
@@ -79,7 +79,7 @@ protected GrpcReadStreamBase(Context context,
     this.maxMessageSize = maxMessageSize;
     this.stream = stream;
     this.format = format;
-    this.queue = new InboundMessageQueue<>(ctx.eventLoop(), ctx.executor(), 8, 16) {
+    this.queue = new InboundMessageChannel<>(ctx.eventLoop(), ctx.executor(), 8, 16) {
       @Override
       protected void handleResume() {
         stream.resume();