var chat = io.of('/chat') .on('connection', roomConnect); // nameSpace
function roomConnect(socket){ // heandler
socket.join('room', function(){
chat.to('room').emit('message', 'somemessage'); // message to room
}) // join in room
}async.parallel([getBalance(123123)], function(err, result){
if (err) return next(err); //<- custom error handler
// do result;
console.log(result);
});var getBalance = (callback) => {
connection.query('SELECT balance FROM Users WHERE id = ?', id, (error, result, fields) => {
if(error)
return callback(error);
if(result[0]['balance'])
callback(null, result[0]['balance']);
});
callback(null, 0);
}async.waterfall([
(callback) => {
// do something
if(result.name !== 'some' && i <= 5) callback(null, data);
return callback('err');
},
(data, callback) => {
return callback(result.reduce((lastRequestDone, item) => {
return lastRequestDone.then(() => somefunc());
}));
}
], function(err, result) {
if (err) return callback(err);
// do something
});