MzMLStAXParser.java 文件源码

private T getNextSpectrumFromSeekable() {
    FromXMLStreamBuilder<T> spectrumBuilder = null;
    try {
        InputStream is = Channels.newInputStream(this.seekable);
        XMLStreamReader xr = XMLInputFactory.newInstance()
            .createXMLStreamReader(is);

        while (xr.hasNext()) {
            xr.next();

            if (spectrumBuilder != null) {
                spectrumBuilder.accept(xr);
            }

            if(xr.getEventType() == XMLStreamReader.START_ELEMENT){
                if(xr.getLocalName().equals("spectrum")) {
                    spectrumBuilder = this.factory.create(this.xml.toString(), xr);
                } else if( xr.getLocalName().equals("referenceableParamGroupRef")) {
                    LOGGER.log(Level.WARN, "Random access to spectra will not parse referenceable params");
                }
            } else if(xr.getEventType() == XMLStreamReader.END_ELEMENT) {
                if(xr.getLocalName().equals("spectrum")) {
                    return spectrumBuilder.build();
                }                   
            }
        }
    } catch (XMLStreamException | FactoryConfigurationError e) {
        LOGGER.log(Level.ERROR, e.toString());
    } 

    return null;
}