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

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