diff options
Diffstat (limited to 'jetty-http2/http2-http-client-transport/src/main/java/org/eclipse/jetty/http2/client/http/HttpSenderOverHTTP2.java')
-rw-r--r-- | jetty-http2/http2-http-client-transport/src/main/java/org/eclipse/jetty/http2/client/http/HttpSenderOverHTTP2.java | 12 |
1 files changed, 2 insertions, 10 deletions
diff --git a/jetty-http2/http2-http-client-transport/src/main/java/org/eclipse/jetty/http2/client/http/HttpSenderOverHTTP2.java b/jetty-http2/http2-http-client-transport/src/main/java/org/eclipse/jetty/http2/client/http/HttpSenderOverHTTP2.java index db01d33c17..b13e68e097 100644 --- a/jetty-http2/http2-http-client-transport/src/main/java/org/eclipse/jetty/http2/client/http/HttpSenderOverHTTP2.java +++ b/jetty-http2/http2-http-client-transport/src/main/java/org/eclipse/jetty/http2/client/http/HttpSenderOverHTTP2.java @@ -33,8 +33,6 @@ import org.eclipse.jetty.util.Promise; public class HttpSenderOverHTTP2 extends HttpSender { - private Stream stream; - public HttpSenderOverHTTP2(HttpChannelOverHTTP2 channel) { super(channel); @@ -59,7 +57,7 @@ public class HttpSenderOverHTTP2 extends HttpSender @Override public void succeeded(Stream stream) { - HttpSenderOverHTTP2.this.stream = stream; + getHttpChannel().setStream(stream); stream.setIdleTimeout(request.getIdleTimeout()); if (content.hasContent() && !expects100Continue(request)) @@ -95,15 +93,9 @@ public class HttpSenderOverHTTP2 extends HttpSender } else { + Stream stream = getHttpChannel().getStream(); DataFrame frame = new DataFrame(stream.getId(), content.getByteBuffer(), content.isLast()); stream.data(frame, callback); } } - - @Override - protected void reset() - { - super.reset(); - stream = null; - } } |