netty: complete promise when RequestMessagesCommand

This commit is contained in:
Jakob Buchgraber 2016-09-13 21:41:56 +02:00 committed by GitHub
parent a702102e41
commit af2434375a
1 changed files with 1 additions and 0 deletions

View File

@ -317,6 +317,7 @@ class NettyServerHandler extends AbstractNettyHandler {
sendResponseHeaders(ctx, (SendResponseHeadersCommand) msg, promise); sendResponseHeaders(ctx, (SendResponseHeadersCommand) msg, promise);
} else if (msg instanceof RequestMessagesCommand) { } else if (msg instanceof RequestMessagesCommand) {
((RequestMessagesCommand) msg).requestMessages(); ((RequestMessagesCommand) msg).requestMessages();
promise.setSuccess();
} else if (msg instanceof CancelServerStreamCommand) { } else if (msg instanceof CancelServerStreamCommand) {
cancelStream(ctx, (CancelServerStreamCommand) msg, promise); cancelStream(ctx, (CancelServerStreamCommand) msg, promise);
} else if (msg instanceof ForcefulCloseCommand) { } else if (msg instanceof ForcefulCloseCommand) {