10 examples of 'node js response end' in JavaScript

16
var end = function end() {
17
  var config = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};
18
19
  return function handler(callback) {
20
    var _this = this;
21
22
    var callbackParam = config.callbackParam || 'callback';
23
    var callbackName = config.callbackName || 'superagentCallback' + (new Date().valueOf() + parseInt(Math.random() * 1000, 10));
24
    var timeoutLimit = config.timeout || 1000;
25
26
    var timeout = setTimeout(jsonp.errorWrapper.bind(this), timeoutLimit);
27
28
    this._jsonp = {
29
      callbackName: callbackName,
30
      callback: callback,
31
      timeout: timeout
32
    };
33
34
    window[callbackName] = jsonp.callbackWrapper.bind(this);
35
36
    this._query.push(encodeURIComponent(callbackParam) + '=' + encodeURIComponent(callbackName));
37
    var queryString = this._query.join('&');
38
39
    var s = document.createElement('script');
40
    {
41
      var separator = this.url.indexOf('?') > -1 ? '&' : '?';
42
      var url = this.url + separator + queryString;
43
44
      s.src = url;
45
46
      // Handle script load error #27
47
      s.onerror = function (e) {
48
        jsonp.errorWrapper.call(_this, e);
49
      };
50
    }
51
52
    document.head.appendChild(s);
53
    this._jsonp.script = s;
54
55
    return this;
56
  };
57
};

233
writable.end = function end ( data /*, encoding */ ) {
234
235
  readable = startResponse( readable );
236
237
  if ( data ) {
238
    readable.emit( 'data', createWritableChunk( data ) );
239
  }
240
241
  readable.emit( 'end' );
242
  return helper;
243
244
} // writable.end

141
end(data,encoding) {
142
	return new Promise((resolve,reject)=>{
143
		try {
144
			this.original.end(data,encoding,(err)=>{
145
				if (err) reject(err);
146
				else resolve();
147
			});
148
		}
149
		catch (ex) {
150
			return reject(ex);
151
		}
152
	});
153
}

52
public end() {
53
  this.mockedEnd();
54
}

271
value: function end(chunk) {
272
  // works only in data mode
273
  if (!this._dataMode) {
274
    // this line should never be reached but if it does,
275
    // act like everything's normal.
276
    return true;
277
  }
278
279
  if (chunk && chunk.length) {
280
    this.send(chunk);
281
  }
282
283
  // redirect output from the server to _actionStream
284
  this._currentAction = this._actionStream;
285
286
  // indicate that the stream has ended by sending a single dot on its own line
287
  // if the client already closed the data with \r\n no need to do it again
288
  if (this._lastDataBytes === '\r\n') {
289
    this.waitDrain = this._send(new Uint8Array([0x2E, 0x0D, 0x0A]).buffer); // .\r\n
290
  } else if (this._lastDataBytes.substr(-1) === '\r') {
291
    this.waitDrain = this._send(new Uint8Array([0x0A, 0x2E, 0x0D, 0x0A]).buffer); // \n.\r\n
292
  } else {
293
    this.waitDrain = this._send(new Uint8Array([0x0D, 0x0A, 0x2E, 0x0D, 0x0A]).buffer); // \r\n.\r\n
294
  }
295
296
  // end data mode, reset the variables for extending the timeout in data mode
297
  this._dataMode = false;
298
  this._socketTimeoutStart = false;
299
  this._socketTimeoutPeriod = false;
300
301
  return this.waitDrain;
302
}

74
check(function end () {
75
    if (--times === 0) {
76
        t.end();
77
    }
78
    else check(end);
79
});

31
MockTtsRequest.prototype.__end = function __end () {
32
  if (!this.playing) {
33
    return
34
  }
35
  this.playing = false
36
  currHandle = null
37
  process.nextTick(() => {
38
    this.handle.emit('end', this.id)
39
  })
40
}

937
Iterator.prototype.end = function end() {
938
  return new Promise((resolve, reject) => {
939
    this.cleanup();
940
    this.iter.end(wrap(resolve, reject));
941
  });
942
};

40
value: function end() {
41
  console.log('Time to get cooking! 🍽 ');
42
}

66
end() {
67
  this.spawnCommandSync('git', ['init'], {
68
    cwd: this.destinationPath()
69
  });
70
71
  // prioritize given repo URL if present
72
  if (this.options.githubUrl) {
73
    this.spawnCommandSync('git', ['remote', 'add', 'origin', this.pkg.repository.url], {
74
      cwd: this.destinationPath()
75
    });
76
  } else if (!this.originUrl) {
77
    var repoSSH = this.pkg.repository;
78
    var url = this.pkg.repository && this.pkg.repository.url;
79
    if (url && url.indexOf('.git') === -1) {
80
      repoSSH = 'git@github.com:' + this.pkg.repository.url + '.git';
81
    }
82
    this.spawnCommandSync('git', ['remote', 'add', 'origin', repoSSH], {
83
      cwd: this.destinationPath()
84
    });
85
  }
86
}