Gecko [ c.stage.kornherr.net ]

Name	Size	Permission	Date
IRIs.js	808 B	-rw-r--r--	2022-11-26 17:24
N3DataFactory.js	10.58 KB	-rw-r--r--	2022-11-26 17:24
N3Lexer.js	20.2 KB	-rw-r--r--	2022-11-26 17:24
N3Parser.js	37.45 KB	-rw-r--r--	2022-11-26 17:24
N3Store.js	31.69 KB	-rw-r--r--	2022-11-26 17:24
N3StreamParser.js	1.72 KB	-rw-r--r--	2022-11-26 17:24
N3StreamWriter.js	1.45 KB	-rw-r--r--	2022-11-26 17:24
N3Util.js	2.54 KB	-rw-r--r--	2022-11-26 17:24
N3Writer.js	14.74 KB	-rw-r--r--	2022-11-26 17:24
index.js	4.71 KB	-rw-r--r--	2022-11-26 17:24

Rename

"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.default = void 0;

var _N3Parser = _interopRequireDefault(require("./N3Parser"));

var _readableStream = require("readable-stream");

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

// **N3StreamParser** parses a text stream into a quad stream.
// ## Constructor
class N3StreamParser extends _readableStream.Transform {
  constructor(options) {
    super({
      decodeStrings: true
    });
    this._readableState.objectMode = true; // Set up parser with dummy stream to obtain `data` and `end` callbacks

const parser = new _N3Parser.default(options);
    let onData, onEnd;
    parser.parse({
      on: (event, callback) => {
        switch (event) {
          case 'data':
            onData = callback;
            break;

case 'end':
            onEnd = callback;
            break;
        }
      }
    }, // Handle quads by pushing them down the pipeline
    (error, quad) => {
      error && this.emit('error', error) || quad && this.push(quad);
    }, // Emit prefixes through the `prefix` event
    (prefix, uri) => {
      this.emit('prefix', prefix, uri);
    }); // Implement Transform methods through parser callbacks

this._transform = (chunk, encoding, done) => {
      onData(chunk);
      done();
    };

this._flush = done => {
      onEnd();
      done();
    };
  } // ### Parses a stream of strings

import(stream) {
    stream.on('data', chunk => {
      this.write(chunk);
    });
    stream.on('end', () => {
      this.end();
    });
    stream.on('error', error => {
      this.emit('error', error);
    });
    return this;
  }

}

exports.default = N3StreamParser;