fix(tests): cleanup post fix

Author: davidyaha

src/test/integration-tests.ts

@@ -128,18 +128,20 @@ describe('Subscribe to buffer', () => {
     // when using messageBuffer, with redis instance the channel name is not a string but a buffer
     const pubSub = new RedisPubSub({ messageEventName: 'messageBuffer'});
     const payload = 'This is amazing';
+    let subId;
     pubSub.subscribe('Posts', message => {
       try {
         expect(message).to.be.instanceOf(Buffer);
         expect(message.toString('utf-8')).to.be.equal(payload);
+        pubSub.unsubscribe(subId);
         done();
       } catch (e) {
         done(e);
       }
     }).then(async subId => {
       try {
         await pubSub.publish('Posts', Buffer.from(payload, 'utf-8'));
-        // pubSub.unsubscribe(subId);
+        subId = subId;
       } catch (e) {
         done(e);
       }