如何创建一个返回等待EventEmitter的promise的函数

Question

当使用JS库时，该库使用EventEmitters来表示调用启动函数后返回的结果，如何使用调用启动函数然后返回等待发出事件的Promise的函数来包装库？

更新：在本例中，使用唯一标识符将请求与返回的结果进行匹配。

例如：

var Class = (function() {
    Class = function() {
        self = this
        self.transactionid = undefined
        self.result = undefined
        self.client = new Client({
            clientId: 0,
            host: '127.0.0.1',
            port: 4001
        }).on('received', function (tokens) {
            console.info('%s %s', '<<< RECV <<<'.cyan, JSON.stringify(tokens))
            // I wish to return `tokens` here via the promise
            if( tokens[ 0 ] == self.transactionid ) 
              self.result = tokens[ 1 ]
        }).on('sent', function (tokens) {
            console.info('%s %s', '>>> SENT >>>'.yellow, JSON.stringify(tokens))
        })
        self.client.connect()
    }
    Class.prototype.request = function( id ) {
        return $q( function( resolve, reject ) {
            self.transactionid = 1000
            self.client.requestData( transactionid, { key: '1234' }, '', false)
            var data = '<want to wait for / return token data here>'            
            // possibly use a dictionary to track different transactions and results?
            resolve( data )
        })
    }
    return Class
})()

Answer 1

如果您将"return tokens via the promise"改为"resolve a Deferred associated with this transaction id"，那么您最终会得到一个非常像常规promise缓存的东西——除了这里需要一个Deferred缓存。

幸运的是$q（与q类似，但与Bluebird或原生Promise不同）为这种情况提供了Deferred，在这种情况下，Promise创建和Promise结算松散耦合或错位。

var Class = (function() {
    Class = function() {
        self = this;
        self.transactions = {}; // a cache of Deferred objects
        self.client = new Client({
            clientId: 0,
            host: '127.0.0.1',
            port: 4001
        }).on('received', function (tokens) {
            console.info('%s %s', '<<< RECV <<<'.cyan, JSON.stringify(tokens));
            self.transactions[tokens[0]].resolve(tokens[1]);
        }).on('sent', function(tokens) {
            console.info('%s %s', '>>> SENT >>>'.yellow, JSON.stringify(tokens));
        });
        self.client.connect();
    };
    Class.prototype.request = function(id) {
        if(!this.transactions[id]) {
            this.transactions[id] = $q.defer();// a Deferred object to be deferred in the onReceived handler
            this.client.requestData( id, { key: '1234' }, '', false);
        }
        return this.transactions[id].promise;
    }
    return Class;
})();

错误处理似乎是一个更大的问题。您可以重新引入一个oneror处理程序，但除非其error对象包含id属性，否则您没有从this.transactions检索相应Deferred的键。

所以，要么：

• 修改Client（）类以传递具有id属性的错误对象
• 在创建请求的位置，在超时后拒绝Deferred

甚至可能两者都有。