public synchronized void close() {
        try {
            in.close();
            queue.clear();
        } catch (Exception ex) {
            // ignore
            log.warn("Failed to close InputStream", ex);
        }
    }
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