如何模拟`createReadStream`上的EventEmitter？

Question

我试图写一个测试用例时错误地发出这个代码的结果：

s3.getObject({ 
    Bucket: mediaBucket, 
    Key: mediaId, 
    }).createReadStream() 

我有一个虚拟S3对象的测试，和我使用的MemoryStream到涵盖呼叫成功的情况。我如何发出错误，所以我可以编写一个测试，让我测试.on('error') function(error)..中的行为？

下面是我尝试过，没有成功：

beforeEach(function() { 
    var emitter = new EventEmitter; 
    const s3 = { 
    getObject:() => { 
     return { createReadStream:() => emitter.emit('error', new Error('Random error!')) } 
    }, 
}; 

Answer 1

就发出像使用任何其他事件：

stream.emit('error', new Error('Random error!')); 

所以，上面的代码应该是这样的：

const s3 = { 
    getObject:() => { 
    return { createReadStream:() => { 
     process.nextTick(function() { 
     emitter.emit('error', new Error('whoops!')); 
     }); 
     return emitter; 
    } } 
    }, 
};