diff options
Diffstat (limited to 'jetty-http2/http2-client/src/test/java/org/eclipse/jetty/http2/client/StreamCountTest.java')
-rw-r--r-- | jetty-http2/http2-client/src/test/java/org/eclipse/jetty/http2/client/StreamCountTest.java | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/jetty-http2/http2-client/src/test/java/org/eclipse/jetty/http2/client/StreamCountTest.java b/jetty-http2/http2-client/src/test/java/org/eclipse/jetty/http2/client/StreamCountTest.java index 7a65df8fa1..2072e1b011 100644 --- a/jetty-http2/http2-client/src/test/java/org/eclipse/jetty/http2/client/StreamCountTest.java +++ b/jetty-http2/http2-client/src/test/java/org/eclipse/jetty/http2/client/StreamCountTest.java @@ -89,7 +89,7 @@ public class StreamCountTest extends AbstractTest HttpFields fields = new HttpFields(); MetaData.Request metaData = newRequest("GET", fields); - HeadersFrame frame1 = new HeadersFrame(1, metaData, null, false); + HeadersFrame frame1 = new HeadersFrame(metaData, null, false); FuturePromise<Stream> streamPromise1 = new FuturePromise<>(); final CountDownLatch responseLatch = new CountDownLatch(1); session.newStream(frame1, streamPromise1, new Stream.Listener.Adapter() @@ -103,7 +103,7 @@ public class StreamCountTest extends AbstractTest }); Stream stream1 = streamPromise1.get(5, TimeUnit.SECONDS); - HeadersFrame frame2 = new HeadersFrame(3, metaData, null, false); + HeadersFrame frame2 = new HeadersFrame(metaData, null, false); FuturePromise<Stream> streamPromise2 = new FuturePromise<>(); session.newStream(frame2, streamPromise2, new Stream.Listener.Adapter()); @@ -117,7 +117,7 @@ public class StreamCountTest extends AbstractTest // Expected } - stream1.data(new DataFrame(stream1.getId(), BufferUtil.EMPTY_BUFFER, true), new Callback.Adapter()); + stream1.data(new DataFrame(stream1.getId(), BufferUtil.EMPTY_BUFFER, true), Callback.NOOP); Assert.assertTrue(responseLatch.await(5, TimeUnit.SECONDS)); } @@ -153,7 +153,7 @@ public class StreamCountTest extends AbstractTest HttpFields fields = new HttpFields(); MetaData.Request metaData = newRequest("GET", fields); - HeadersFrame frame1 = new HeadersFrame(1, metaData, null, false); + HeadersFrame frame1 = new HeadersFrame(metaData, null, false); FuturePromise<Stream> streamPromise1 = new FuturePromise<>(); final CountDownLatch responseLatch = new CountDownLatch(1); session.newStream(frame1, streamPromise1, new Stream.Listener.Adapter() @@ -168,7 +168,7 @@ public class StreamCountTest extends AbstractTest Stream stream1 = streamPromise1.get(5, TimeUnit.SECONDS); - HeadersFrame frame2 = new HeadersFrame(3, metaData, null, false); + HeadersFrame frame2 = new HeadersFrame(metaData, null, false); FuturePromise<Stream> streamPromise2 = new FuturePromise<>(); session.newStream(frame2, streamPromise2, new Stream.Listener.Adapter() { @@ -182,7 +182,7 @@ public class StreamCountTest extends AbstractTest streamPromise2.get(5, TimeUnit.SECONDS); Assert.assertTrue(resetLatch.await(5, TimeUnit.SECONDS)); - stream1.data(new DataFrame(stream1.getId(), BufferUtil.EMPTY_BUFFER, true), new Callback.Adapter()); + stream1.data(new DataFrame(stream1.getId(), BufferUtil.EMPTY_BUFFER, true), Callback.NOOP); Assert.assertTrue(responseLatch.await(5, TimeUnit.SECONDS)); } } |