From af2434375aae184aa1780b412f1aeff3a85bd21c Mon Sep 17 00:00:00 2001 From: Jakob Buchgraber Date: Tue, 13 Sep 2016 21:41:56 +0200 Subject: [PATCH] netty: complete promise when RequestMessagesCommand --- netty/src/main/java/io/grpc/netty/NettyServerHandler.java | 1 + 1 file changed, 1 insertion(+) diff --git a/netty/src/main/java/io/grpc/netty/NettyServerHandler.java b/netty/src/main/java/io/grpc/netty/NettyServerHandler.java index c2230792c2..640e9f02b6 100644 --- a/netty/src/main/java/io/grpc/netty/NettyServerHandler.java +++ b/netty/src/main/java/io/grpc/netty/NettyServerHandler.java @@ -317,6 +317,7 @@ class NettyServerHandler extends AbstractNettyHandler { sendResponseHeaders(ctx, (SendResponseHeadersCommand) msg, promise); } else if (msg instanceof RequestMessagesCommand) { ((RequestMessagesCommand) msg).requestMessages(); + promise.setSuccess(); } else if (msg instanceof CancelServerStreamCommand) { cancelStream(ctx, (CancelServerStreamCommand) msg, promise); } else if (msg instanceof ForcefulCloseCommand) {