fix(subscriber): pass message to ack

package.json

@@ -1,14 +1,14 @@
 {
   "name": "rxamqp",
-  "version": "0.2.13",
+  "version": "0.2.14",
   "description": "Library for easy amqplib configuration and usage",
   "main": "./src/index.js",
   "scripts": {
     "start": "nodemon ./src/index.js",
     "start:test": "nodemon ./src/test.js",
     "lint": "eslint src",
     "test": "jest --coverage --collectCoverageFrom --forceExit spec",
-    "test:watch": "nodemon --watch . --exec 'jest --runInBand spec'",
+    "test:watch": "jest --watchAll --runInBand",
     "playground": "nodemon ./src/test.js"
   },
   "author": {
@@ -17,7 +17,7 @@
   },
   "repository": {
     "type": "git",
-    "url": "https://github.com/ygrishajev/amqpRx"
+    "url": "https://github.com/ygrishajev/rxamqp"
   },
   "license": "MIT",
   "keywords": [

spec/client.spec.js

@@ -24,8 +24,6 @@ afterEach(() => client.shutdown())
 
 describe('Client', () => {
   test('#publish message payload is properly delivered subscriber', () => {
-    expect.assertions(1)
-
     return new Promise(resolve => {
       use((msg, ctx) => {
         ctx.ack().then(() => resolve(msg))

src/subscriber.js

@@ -55,7 +55,7 @@ module.exports = context => {
       data: payload,
       status: status || 200
     }, message, { ack: true }),
-    ack,
+    ack: () => ack(message),
     reject: (requeue = false) => {
       context.events.emit('event.nack', message)
       return context.channel.reject(message, requeue)