We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5421875 commit 1149488Copy full SHA for 1149488
consumer.js
@@ -45,7 +45,7 @@ Consumer.prototype.handleMessage = function (msg) {
45
46
Consumer.prototype.handleEvent = function (event, callback) {
47
if (!event.type) throw new Error('Missing event type');
48
- if (!this.projections[event.type]) throw new Error('No projections for ' + event.type);
+ if (!this.projections[event.type]) return callback(new Error('No projection found for ' + event.type));
49
this.projections[event.type].bind(this)(event.data || event.args || {}, callback);
50
};
51
0 commit comments