final HttpResponse response = ch.readOutbound();
assertThat(response.getStatus(), equalTo(HttpResponseStatus.OK));
//Read and discard prelude
ch.readOutbound();
final DefaultHttpContent openResponse = ch.readOutbound();
assertThat(openResponse.content().toString(UTF_8), equalTo("o\n"));
final EmbeddedChannel ch2 = channelForService(serviceFactory);
removeLastInboundMessageHandlers(ch2);
final FullHttpRequest request2 = httpRequest(sessionUrl + Transports.Type.XHR_STREAMING.path(), POST);
ch2.writeInbound(request2);