[email protected], export Packet and fixed test (#53)

moscajs · Feb 27, 2020 · cb704b7 · cb704b7
1 parent 0602e42
commit cb704b7
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/abstract.js b/abstract.js
@@ -906,11 +906,12 @@ function abstractPersistence (opts) {
     }
     var queue = []
     enqueueAndUpdate(t, instance, client, sub, packet1, 42, function (updated1) {
-      enqueueAndUpdate(t, instance, client, sub, packet2, 42, function (updated2) {
+      enqueueAndUpdate(t, instance, client, sub, packet2, 43, function (updated2) {
         var stream = instance.outgoingStream(client)
         pump(stream, through.obj(function clearQueue (data, enc, next) {
           instance.outgoingUpdate(client, data,
-            function (_, client, packet) {
+            function (err, client, packet) {
+              t.notOk(err, 'no error')
               queue.push(packet)
               next()
             })

diff --git a/package.json b/package.json
@@ -71,7 +71,7 @@
     "through2": "^3.0.1"
   },
   "dependencies": {
-    "aedes-packet": "^2.1.0",
+    "aedes-packet": "^2.3.1",
     "from2": "^2.3.0",
     "qlobber": "^5.0.0"
   }

diff --git a/persistence.js b/persistence.js
@@ -355,3 +355,4 @@ MemoryPersistence.prototype.destroy = function (cb) {
 }
 
 module.exports = MemoryPersistence
+module.exports.Packet = Packet
Original file line number	Diff line number	Diff line change
Expand Up		@@ -355,3 +355,4 @@ MemoryPersistence.prototype.destroy = function (cb) {
		}

		module.exports = MemoryPersistence
		module.exports.Packet = Packet