import(stream) {
        const output = new stream_1.PassThrough({ readableObjectMode: true });
        stream.on('error', (error) => parsed.emit('error', error));
        stream.on('data', (data) => output.write(data));
        stream.on('end', () => output.emit('end'));
        const parsed = output.pipe(new RdfXmlParser(this.options));
        return parsed;
    }
/**
     * Parses the given text stream into a quad stream.
     * @param {NodeJS.EventEmitter} stream A text stream.
     * @return {RDF.Stream} A quad stream.
     */
Parses the given text stream into a quad stream.
Parses the given text stream into a quad stream .
import(stream) {
        const output = new stream_1.PassThrough({ readableObjectMode: true });
        stream.on('error', (error) => parsed.emit('error', error));
        stream.on('data', (data) => output.write(data));
        stream.on('end', () => output.emit('end'));
        const parsed = output.pipe(new RdfXmlParser(this.options));
        return parsed;
    }
import ( stream ) { const output = new stream_1 . PassThrough ( { readableObjectMode : true } ) ; stream . on ( 'error' , ( error ) => parsed . emit ( 'error' , error ) ) ; stream . on ( 'data' , ( data ) => output . write ( data ) ) ; stream . on ( 'end' , ( ) => output . emit ( 'end' ) ) ; const parsed = output . pipe ( new RdfXmlParser ( this . options ) ) ; return parsed ; }
Parses the given text stream into a quad stream.
Parses the given text stream into a quad stream .