@Test
void testOnHeadersRead_headersStreamContinuing() throws Exception {

  testHandler = new Http2Handler(mockEncoder, MAX_PAYLOAD, NO_CORS);
  headers.method("GET").path(PARAM_PATH_PREFIX + "/group");
  // Call with endOfStream set to false; we shouldn't see a response.
  testHandler.onHeadersRead(mockContext, STREAM_ID, headers, 1, false);
  assertEquals(1L, requestMeter.getCount());
  verifyNoResponse();
  // Verify that the request and handler were queued up.
  XrpcRequest xrpcRequest = testHandler.requests.get(STREAM_ID);
  assertNotNull(xrpcRequest);
  assertEquals(headers, xrpcRequest.h2Headers());
  assertEquals("group", xrpcRequest.variable(PARAM_NAME));
  Handler handler = testHandler.handlers.get(STREAM_ID);
  assertNotNull(handler);
  assertEquals(HttpResponseStatus.OK, handler.handle(xrpcRequest).status());
}