public void setEos() {
        eos.set(true);
        buffers.add(EMPTY_BUFFER); // to wake the BlockingQueue
    }
Marks {@link InputStream} with the EOS, meaning that there will be no more
{@link ByteBuf} data chunks available to this {@link InputStream}.
core/src/main/java/com/linecorp/armeria/internal/common/stream/ByteBufsInputStream.java