Skip to content

Instantly share code, notes, and snippets.

var request = require('request').forever()
, pool = { maxSockets: 1 };
request({ url: '...', pool: pool, timeout: 10}, function(error, response, body) {
console.log(body);
});
setTimeout(function () {request({ url: '...', pool : pool}, function(error, response, body) {
});}, 2000);
var http = require ('http');
http.createServer(function (req, res) {
console.log('received request');
}).listen(9002);
var httprequest = require('request');
httprequest({
'pool.maxSockets': 1,
url: "http://127.0.0.1:9002"}, function (error, response, body) {
console.log('one');
}
);
var request = require('request');
httprequest({
headers: {
connection: 'keep-alive'
},
'pool.maxSockets': 1, //hopefully will make Node to reuse the connection next time it connects to the same host (instead of creating a new connection)
url: "http://www.google.com"}, function (error, response, body) {
console.log('');
function error () {
console.log("timed out");
}
function main () {
setTimeout(function () {
error();
//halt
}, 1);
var dnode = require('dnode');
var stuff = "the stuff";
var server = dnode({
getStuff : function (cb) {
cb(stuff);
}
});
var dnode = require('dnode');
var stuff;
var async = require('async');
d = dnode.connect(9000);
d.on('remote', function(remote){
async.series([function (callback) {
var fs = require ('fs'),
async = require ('async');
var q = async.queue(function (task, callback){
fs.appendFile('UIDs.txt', task.value + '\n', function (err) {
callback();
});
}, 250);
var fs = require ('fs'),
async = require ('async');
var q = async.queue(function (task, callback){
fs.appendFile('UIDs.txt', task.value + '\n');
callback();
}, 250);
for (i = 1; i <= 1972100; i++) {
var fs = require ('fs');
var log = fs.createWriteStream('UIDs.txt', {'flags': 'a'});
for (var i = 1; i <= 1972100; i++) {
log.write(i + "\n");
};