@Test(timeout = 10000)
public void simpleRead() throws IOException {

    testChannel = new TestPipeChannel();
    PipeChannelInputStream input = new PipeChannelInputStream(testChannel, Duration.ofSeconds(2));
    String msg = "Hello world!";
    testChannel.printToReadBuffer(msg);
    byte[] buffer = new byte[4096];
    int n = input.read(buffer);
    assertThat(new String(buffer, 0, n, StandardCharsets.UTF_8)).isEqualTo(msg);
    mustBlock(input::read);
}