1234567891011121314151617181920212223242526272829303132333435 |
- module.exports = Stream;
-
- var Parser = require("./WritableStream.js");
-
- function Stream(options) {
- Parser.call(this, new Cbs(this), options);
- }
-
- require("inherits")(Stream, Parser);
-
- Stream.prototype.readable = true;
-
- function Cbs(scope) {
- this.scope = scope;
- }
-
- var EVENTS = require("../").EVENTS;
-
- Object.keys(EVENTS).forEach(function(name) {
- if (EVENTS[name] === 0) {
- Cbs.prototype["on" + name] = function() {
- this.scope.emit(name);
- };
- } else if (EVENTS[name] === 1) {
- Cbs.prototype["on" + name] = function(a) {
- this.scope.emit(name, a);
- };
- } else if (EVENTS[name] === 2) {
- Cbs.prototype["on" + name] = function(a, b) {
- this.scope.emit(name, a, b);
- };
- } else {
- throw Error("wrong number of arguments!");
- }
- });
|