Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
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.java12
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));
}
}

Back to the top