Comparing version 2.0.0-beta.15 to 2.0.0-beta.16
@@ -136,3 +136,3 @@ const CallableInstance = require('callable-instance') | ||
this._emitter.emit(`data-${message.properties.messageId}`, ...content) | ||
this._emitter.emit(`data-${message.properties.correlationId}`, ...content) | ||
} | ||
@@ -139,0 +139,0 @@ |
{ | ||
"name": "remit", | ||
"version": "2.0.0-beta.15", | ||
"version": "2.0.0-beta.16", | ||
"description": "A small set of functionality used to create microservices that don't need to be aware of one-another's existence.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -196,3 +196,14 @@ /* global describe, it, before */ | ||
it('should return data early from synchronous middleware') | ||
it('should return data early from synchronous middleware', async function () { | ||
const endpoint = await remit | ||
.endpoint('return-4') | ||
.handler((event, callback) => { | ||
callback(null, 'foobar4') | ||
}) | ||
.start() | ||
const result = await remit.request('return-4')() | ||
expect(result).to.equal('foobar4') | ||
}) | ||
it('should return data early from promises middleware') | ||
@@ -199,0 +210,0 @@ it('should return data early from callback middleware') |
57678
1220