Skip to content

Commit

Permalink
Fix
Browse files Browse the repository at this point in the history
  • Loading branch information
valeriansaliou committed May 17, 2024
1 parent ab5ddf2 commit ab37ded
Showing 1 changed file with 9 additions and 8 deletions.
17 changes: 9 additions & 8 deletions lib/mirage.js
Original file line number Diff line number Diff line change
Expand Up @@ -297,18 +297,19 @@ Mirage.prototype.__doPostStream = function(
} else {
var dataPartObject = JSON.parse(dataPart);

// Acquire event name
// Important: add prefix if event streamed from Mirage is \
// a reserved event (eg. 'error' becomes ':error').
var eventName = (eventBlock || "data");

if (STREAM_RESERVED_EVENTS.includes(eventName) === true) {
eventName = (":" + eventName);
}

// Process at next event loop tick, as the 'data' event might \
// come out-of-order.
setImmediate(function() {
// Raise event (fallback to 'data' if no event block)
// Important: add prefix if event streamed from Mirage is \
// a reserved event (eg. 'error' becomes ':error').
var eventName = (eventBlock || "data");

if (STREAM_RESERVED_EVENTS.includes(eventName) === true) {
eventName = (":" + eventName);
}

emitter.emit(eventName, dataPartObject);
});
}
Expand Down

0 comments on commit ab37ded

Please sign in to comment.