@Test
@SneakyThrows
public void testConsumeReturnsLinesCorrectly() {

    when(bufferedReaderMock.readLine()).thenReturn("aaa", "bbb", "ccc", null);
    final Flux<String> result = bufferedReaderAdapter.consume().apply(bufferedReaderMock);
    StepVerifier.create(result)
            .consumeNextWith(a -> assertThat(a, is("aaa")))
            .consumeNextWith(a -> assertThat(a, is("bbb")))
            .consumeNextWith(a -> assertThat(a, is("ccc")))
            .verifyComplete();
}