diff --git a/redisinsight/api/test/api/ws/pub-sub/pub-sub.test.ts b/redisinsight/api/test/api/ws/pub-sub/pub-sub.test.ts
index b6ae9278e3..3293a7513c 100644
--- a/redisinsight/api/test/api/ws/pub-sub/pub-sub.test.ts
+++ b/redisinsight/api/test/api/ws/pub-sub/pub-sub.test.ts
@@ -130,20 +130,20 @@ describe('pub-sub', function () {
       client.on('p:*', (data) => messages['*'].push(...data.messages));
 
       await new Promise((resolve) => {
-        client.emit('subscribe', { subscriptions: [subscription, subscriptionB, pSubscription] },  async (ack) => {
+        client.emit('subscribe', { subscriptions: [subscription, subscriptionB, pSubscription] },  (ack) => {
           expect(ack).to.eql({ status: 'ok' });
 
           client.on('s:channel-b', resolve);
 
-          await rte.data.sendCommand('publish', ['channel-a', 'message-a']);
-          await rte.data.sendCommand('publish', ['channel-a', 'message-a']);
-          await rte.data.sendCommand('publish', ['channel-a', 'message-a']);
-          await rte.data.sendCommand('publish', ['channel-a', 'message-a']);
-          await rte.data.sendCommand('publish', ['channel-b', 'message-b']);
+          rte.data.sendCommand('publish', ['channel-a', 'message-a']);
+          rte.data.sendCommand('publish', ['channel-a', 'message-a']);
+          rte.data.sendCommand('publish', ['channel-a', 'message-a']);
+          rte.data.sendCommand('publish', ['channel-a', 'message-a']);
+          rte.data.sendCommand('publish', ['channel-b', 'message-b']);
         })
       });
 
-      sleep(3000);
+      await sleep(3000);
 
       expect(messages['channel-a'].length).to.eql(4);
       messages['channel-a'].forEach(message => {