Добавление таймаута для обратного вызова в рамках обещания и отклонения

Question

Я преобразую функцию испускания socket.io в такое обещание.

var io = require("socket.io-client") 
var Promise = require("bluebird") 
var _ = require("underscore") 

io.emitAsync = function(event, payload){ 
    return new Promise(function (resolve, reject) { 
    return io.emit(event, payload, function(){ 
     var args = _.toArray(arguments) 
     if(args[0]) reject(new Error(args[0])) 
     resolve.apply(null, args) 
    }) 
    }) 
} 

я не мог использовать promiseify потому что io.emit обратного вызов не возвращает обратный вызов подписи узла стиля. The first argument can't be an error object. Итак, план состоит в том, чтобы передать строковое сообщение об ошибке, обещание выше будет отклонять, если первый аргумент равен truthy. Это все прекрасно и денди, вот в чем проблема.

Если вы не вернетесь в вашем socket.on того этого обещания в callback выше никогда не будет resolve или reject ничего. Так что мне нужен тайм-аут этого callback, если ничего не возвращается в течение отведенного периода времени, тогда он будет reject(new Error("timeout")). Дело в том, что я не знаю, как это сделать. В идеале я могу установить seconds, чтобы подождать в пределах функции выше, или, если знаете, что нет обратного вызова для данного события, я хотел бы resolve, поэтому в идеале это параметр emitAsync. Мысли?

Answer 1

Вы можете просто использовать Bluebird timeout method конечно ...

Раствор нижнего уровня будет использовать setTimeout:

new Promise(function (resolve, reject) { 
    io.emit(event, payload, function(err){ 
    if(err) reject(new Error(err)) 
    resolve(_.toArray(arguments).slice(1)); 
    }) 
    setTimeout(function(){ 
    reject(new Error("timeout")); 
    }, seconds*1000); 
})