test(amqplib): reduce wait time after channel close (#85)

Author: Amir Blum

packages/instrumentation-amqplib/test/amqplib-promise.spec.ts

@@ -35,8 +35,6 @@ describe('amqplib instrumentation promise model', function () {
     });
     after(async () => {
         await conn.close();
-        // the 'close' event might take some time to arrive
-        await new Promise((resolve) => setTimeout(resolve, 70));
         instrumentation.disable();
     });
 
@@ -83,6 +81,9 @@ describe('amqplib instrumentation promise model', function () {
     afterEach(async () => {
         try {
             channel.close();
+            // the 'close' event on the emitter might take some time to arrive after close promise ends,
+            // we add small timeout to let it settle before going on to next
+            await new Promise((resolve) => setTimeout(resolve, 5));
         } catch {}
         instrumentation.disable();
     });
@@ -224,7 +225,6 @@ describe('amqplib instrumentation promise model', function () {
             channel.ack(msgs[2]);
             channel.ack(msgs[0]);
             // assert all 3 span messages are ended
-            console.log(memoryExporter.getFinishedSpans());
             expect(memoryExporter.getFinishedSpans().length).toBe(6);
             expectConsumeEndSpyStatus([EndOperation.Ack, EndOperation.Ack, EndOperation.Ack]);
         });