HttpTunnelClientSendHandlerTest.java 文件源码

@Test
public void testClose() {
    emulateConnectAndOpen();

    channel.close();
    assertEquals(1, sink.events.size());
    HttpRequest request = NettyTestUtils.checkIsDownstreamMessageEvent(
            sink.events.poll(), HttpRequest.class);
    assertTrue(HttpTunnelMessageUtils.isCloseTunnelRequest(request, USER_AGENT));
    assertEquals("newTunnel",
            HttpTunnelMessageUtils.extractTunnelId(request));
    Channels.fireMessageReceived(channel,
            HttpTunnelMessageUtils.createTunnelCloseResponse());
    assertEquals(1, sink.events.size());
    NettyTestUtils.checkIsStateEvent(sink.events.poll(), ChannelState.OPEN,
            false);
}