Stop consumer

kibertoad · Nov 20, 2023 · ad281cb · ad281cb
1 parent 3281dfd
commit ad281cb
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/packages/sqs/test/consumers/SqsPermissionsConsumerMultiSchema.spec.ts b/packages/sqs/test/consumers/SqsPermissionsConsumerMultiSchema.spec.ts
@@ -141,6 +141,7 @@ describe('SqsPermissionsConsumerMultiSchema', () => {
 
       expect(newConsumer.addCounter).toBe(1)
       expect(barrierCounter).toBe(2)
+      await newConsumer.close()
     })
 
     it('throws an error on first try', async () => {
@@ -166,11 +167,12 @@ describe('SqsPermissionsConsumerMultiSchema', () => {
       })
 
       await waitAndRetry(() => {
-        return newConsumer.addCounter === 1
+        return newConsumer.addCounter > 0
       })
 
       expect(newConsumer.addCounter).toBe(1)
       expect(barrierCounter).toBe(2)
+      await newConsumer.close()
     })
   })