Lines Matching refs:on

162         var csvStream = fastCsv.parse(options.parserOptions).on('data', function (data) {
164         }).on('end', function () {
167         csvStream.on('worksheet', resolve).on('error', reject);
193         stream.on('finish', function () {
196         csvStream.on('error', reject);
6081             saxesParser.on('error', function (err) {
6085             saxesParser.on('opentag', function (value) {
6091             saxesParser.on('text', function (value) {
6097             saxesParser.on('closetag', function (value) {
24217                   streamBuf.on('finish', function () {
24229                   entry.on('error', function (error) {
24354                   entry.on('error', reject);
24355                   stream.on('error', reject);
24356                   stream.on('finish', function () {
25321         zip.on('finish', function () {
25324         zip.on('error', reject);
25450         stream.on('finish', function () {
25453         stream.on('error', function (error) {
26181     ws.on('error', rej).on('finish', function () {
48829 EventEmitter.prototype.on = EventEmitter.prototype.addListener;
48881   this.on(type, _onceWrap(this, type, listener));
50880     worker.on("end", function () {
51600   previous.on('data', function (chunk) {
51603   previous.on('end', function () {
51612   previous.on('error', function (e) {
51816     worker.on("error", function (e) {
51818     }).on("end", function () {
51915   stream.on("data", function (chunk) {
51922   }).on("error", function (e) {
51928   }).on("end", function () {
51984   helper.on("data", function (data, meta) {
51992   }).on("error", function (e) {
51994   }).on("end", function () {
52061 …return obj && typeof obj.on === "function" && typeof obj.pause === "function" && typeof obj.resume…
53187   on: function on(name, listener) {
53242     previous.on('data', function (chunk) {
53245     previous.on('end', function () {
53248     previous.on('error', function (e) {
53473     helper.on('data', function (data, meta) {
53479     }).on('error', function (err) {
53482     }).on('end', function () {
53553   on: function on(evt, fn) {
53557       this._worker.on(evt, function (chunk) {
53561       this._worker.on(evt, function () {
62692 exports.setTyped = function (on) {
62693   if (on) {
70767 process.on = noop;
71725 …if (!emitter._events || !emitter._events[event]) emitter.on(event, fn);else if (Array.isArray(emit…
72253   dest.on('unpipe', onunpipe);
72276   dest.on('drain', ondrain);
72299   src.on('data', ondata);
72426 Readable.prototype.on = function (ev, fn) {
72427   var res = Stream.prototype.on.call(this, ev, fn);
72454 Readable.prototype.addListener = Readable.prototype.on;
72574   stream.on('end', function () {
72584   stream.on('data', function (chunk) {
72611     stream.on(kProxyEvents[n], this.emit.bind(this, kProxyEvents[n]));
72872   this.on('prefinish', prefinish);
73872   stream.on('readable', onReadable.bind(null, iterator));
74332     stream.req.on('finish', onfinish);
74336     stream.on('complete', onfinish);
74337     stream.on('abort', onclose);
74338     if (stream.req) onrequest();else stream.on('request', onrequest);
74341     stream.on('end', onlegacyfinish);
74342     stream.on('close', onlegacyfinish);
74345   stream.on('end', onend);
74346   stream.on('finish', onfinish);
74347   if (opts.error !== false) stream.on('error', onerror);
74348   stream.on('close', onclose);
74404   stream.on('close', function () {
75962     value: function on(name, handler) {
78927   source.on('data', ondata);
78935   dest.on('drain', ondrain); // If the 'end' option is not supplied, dest.end() will be called when
78939     source.on('end', onend);
78940     source.on('close', onclose);
78966   source.on('error', onerror);
78967   dest.on('error', onerror); // remove all the event listeners that were added.
78981   source.on('end', cleanup);
78982   source.on('close', cleanup);
78983   dest.on('close', cleanup);
79281 …if (!emitter._events || !emitter._events[event]) emitter.on(event, fn);else if (isArray(emitter._e…
79740   dest.on('unpipe', onunpipe);
79763   dest.on('drain', ondrain);
79791   src.on('data', ondata);
79917 Readable.prototype.on = function (ev, fn) {
79918   var res = Stream.prototype.on.call(this, ev, fn);
79941 Readable.prototype.addListener = Readable.prototype.on;
80009   stream.on('end', function () {
80019   stream.on('data', function (chunk) {
80046     stream.on(kProxyEvents[n], this.emit.bind(this, kProxyEvents[n]));
80337   this.on('prefinish', prefinish);