br/TACO-137 added streamId to the response in hopes that this will fi…

…x the ci build failure
xjdr · Apr 18, 2018 · d6f24c0 · d6f24c0
1 parent 778858f
commit d6f24c0
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/xio-core/src/test/java/com/xjeffrose/xio/metric/HttpServerMetricHandlerIntegrationTest.java b/xio-core/src/test/java/com/xjeffrose/xio/metric/HttpServerMetricHandlerIntegrationTest.java
@@ -85,21 +85,22 @@ private class TestHandler extends SimpleChannelInboundHandler<Request> {
     protected void channelRead0(ChannelHandlerContext ctx, Request msg) {
 
       if (msg instanceof SegmentedRequestData && msg.endOfMessage()) {
-        sendResponse(ctx);
+        sendResponse(ctx, msg);
         return;
       } else if (msg instanceof FullRequest) {
-        sendResponse(ctx);
+        sendResponse(ctx, msg);
       }
 
       ctx.write(msg);
     }
 
-    private void sendResponse(ChannelHandlerContext ctx) {
+    private void sendResponse(ChannelHandlerContext ctx, Request msg) {
       val resp =
           DefaultFullResponse.builder()
               .headers(new DefaultHeaders())
               .status(HttpResponseStatus.OK)
               .body(Unpooled.EMPTY_BUFFER)
+              .streamId(msg.streamId())
               .build();
       ctx.writeAndFlush(resp);
     }