@Test
void shouldFilterRequest() throws IOException {

    unit.process(request).write();
    final ArgumentCaptor<HttpRequest> captor = ArgumentCaptor.forClass(HttpRequest.class);
    verify(sink).write(any(), captor.capture());
    final HttpRequest request = captor.getValue();
    assertThat(request, instanceOf(FilteredHttpRequest.class));
}