Also provide implementation for flush out of the box

This commit is contained in:
Norman Maurer 2013-04-07 11:54:13 +02:00
parent b36e815026
commit 3305a7df82

View File

@ -23,6 +23,7 @@ import io.netty.channel.ChannelHandlerUtil;
import io.netty.channel.ChannelInboundByteHandler;
import io.netty.channel.ChannelInboundMessageHandler;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.ChannelPromise;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpRequestDecoder;
import io.netty.handler.codec.http.HttpResponseEncoder;
@ -90,6 +91,11 @@ public abstract class SpdyOrHttpChooser extends ChannelDuplexHandler implements
}
}
@Override
public void flush(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception {
ctx.flush(promise);
}
private boolean initPipeline(ChannelHandlerContext ctx) {
// Get the SslHandler from the ChannelPipeline so we can obtain the SslEngine from it.
SslHandler handler = ctx.pipeline().get(SslHandler.class);