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

    testChannel = new TestPipeChannel(4096);
    PipeChannelOutputStream output = new PipeChannelOutputStream(testChannel, Duration.ofSeconds(2));
    String msg = "Hello world!";
    output.write(msg.getBytes(StandardCharsets.UTF_8));
    assertThat(testChannel.readWriteBufferContent()).isEqualTo(msg);
}