@Override
    public synchronized ReadStream<Buffer> fetch(long amount) {
        queue.fetch(amount);
        return this;
    }
Implementation of vertx {@link io.vertx.core.streams.ReadStream} that wraps {@link java.io.InputStream}.
server/src/main/java/com/epam/aidial/core/server/vertx/stream/InputStreamReader.java