/*
* Equivalent to Http11.test_streaming in sockjs-protocol-0.3.3.py.
*/
@Test
public void http11TestStreaming() throws Exception {
final SockJsServiceFactory closeFactory = closeService();
final String sessionUrl = closeFactory.config().prefix() + "/222/" + UUID.randomUUID().toString();
final EmbeddedChannel ch = channelForService(closeFactory);
removeLastInboundMessageHandlers(ch);
final FullHttpRequest request = httpPostRequest(sessionUrl + Transports.Type.XHR_STREAMING.path(), HTTP_1_1);
request.headers().set(CONNECTION, KEEP_ALIVE);
ch.writeInbound(request);