Adapt to vertx-core changes.

eclipse-vertx · Feb 3, 2025 · a4f8e07 · a4f8e07
1 parent 02e7e5d
commit a4f8e07
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.*;
 
@@ -51,7 +51,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;
@@ -75,7 +75,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();