public static ClickHouseInputStream of(BlockingQueue<ByteBuffer> queue, int timeout) {
        return of(queue, timeout, null);
    }
Wraps the given blocking queue.

@param queue   non-null blocking queue
@param timeout read timeout in milliseconds
@return wrapped input
clickhouse-data/src/main/java/com/clickhouse/data/ClickHouseInputStream.java