Skip to content

Commit c189b8f

Browse files
committed
Simplified emit by returning the message
1 parent 8dc952b commit c189b8f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

lib/actions/insert.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ function processAction(msg) {
6060
console.log('Executing statement');
6161
yield pstmt.execute(msg.body);
6262
console.log('Execution completed');
63-
this.emit('data', msg);
63+
return msg;
6464
}.bind(this));
6565
}
6666

0 commit comments

Comments
 (0)