Merge pull request #8 from maticnetwork/enhancement/not-required-empt…

…y-arrow-function-removed Empty arrow function removed
0xPolygon · Aug 28, 2023 · 198d933 · 198d933
2 parents c7eeaa5 + 3485316
commit 198d933
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/internal/kafka/producer/synchronous_producer.ts b/internal/kafka/producer/synchronous_producer.ts
@@ -59,7 +59,9 @@ export class SynchronousProducer extends AbstractProducer {
         timestamp?: number
     ): Promise<DeliveryReport | KafkaError> {
         return new Promise(async (resolve, reject) => {
-            let deliveryListener: (error: LibrdKafkaError, report: DeliveryReport) => void = () => { };
+            // @ts-ignore
+            let deliveryListener: (error: LibrdKafkaError, report: DeliveryReport) => void;
+
             try {
                 const identifier = { time: Date.now() };
                 const timer = setTimeout(() => {
@@ -88,7 +90,9 @@ export class SynchronousProducer extends AbstractProducer {
                         return;
                     }
                 };
+
                 this.on("delivery-report", deliveryListener);
+
                 await this.sendToInternalProducer(
                     key,
                     message,
@@ -102,7 +106,10 @@ export class SynchronousProducer extends AbstractProducer {
                     this.poll();
                 }, 100);
             } catch (error) {
-                this.removeListener("delivery-report", deliveryListener);
+                // @ts-ignore
+                if (deliveryListener) {
+                    this.removeListener("delivery-report", deliveryListener);
+                }
 
                 throw KafkaError.createUnknown(error);
             }