Interface QueuingParser<T>

    • Method Detail

      • parse

        void parse​(InputStream inputStream,
                   BlockingQueue<T> queue)
            throws IOException
        Parse an input stream, storing the results in the passed queue (which can be used by a consumer)
        Parameters:
        inputStream - input stream
        queue - queue
        Throws:
        IOException - IO problems