Redis
 sql >> база данни >  >> NoSQL >> Redis

Изчакайте обратно извикване на асинхронна функция в последното събитие stream.on('data').

Можете да разрешите този проблем с помощта на асинхронна библиотека. Можете да използвате шаблона по-долу за всякакви потоци.

var AsyncLib = require('async');

var worker = function (payload, cb) {
    //do something with payload and call callback
    return cb();
};

var concurrency = 5;
var streamQueue = AsyncLib.queue(worker, concurrency);

var stream = //some readable stream;

stream.on('data', function(data) {
    //no need to pause and resume
    var payload = '//some payload';
    streamQueue.push(payload);
})
.on('end', function() {
    //register drain event on end and callback
    streamQueue.drain = function () {
        callback();
    };
});



  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. съхраняване на данни в redis чрез cron задание

  2. Как да проверя за nil/null в Redis Lua cjson?

  3. Това добър случай ли е на използване на Redis в ServiceStack REST API?

  4. Модулният сокет не е намерен lua

  5. Първи стъпки с клиентски API на Redis