From 3305a7df8278ef121e9c6e57a2db737b5cfce74d Mon Sep 17 00:00:00 2001 From: Norman Maurer Date: Sun, 7 Apr 2013 11:54:13 +0200 Subject: [PATCH] Also provide implementation for flush out of the box --- .../java/io/netty/handler/codec/spdy/SpdyOrHttpChooser.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/codec-http/src/main/java/io/netty/handler/codec/spdy/SpdyOrHttpChooser.java b/codec-http/src/main/java/io/netty/handler/codec/spdy/SpdyOrHttpChooser.java index d1f462a7b1..2adeef33ac 100644 --- a/codec-http/src/main/java/io/netty/handler/codec/spdy/SpdyOrHttpChooser.java +++ b/codec-http/src/main/java/io/netty/handler/codec/spdy/SpdyOrHttpChooser.java @@ -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);