type declaration fixed

0xPolygon · Aug 28, 2023 · 90a4480 · 90a4480
1 parent 5c6d229
commit 90a4480
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/internal/kafka/producer/synchronous_producer.ts b/internal/kafka/producer/synchronous_producer.ts
@@ -59,8 +59,8 @@ export class SynchronousProducer extends AbstractProducer {
         timestamp?: number
     ): Promise<DeliveryReport | KafkaError> {
         return new Promise(async (resolve, reject) => {
-            let deliveryListener: (error: LibrdKafkaError, report: DeliveryReport) => void;
-            
+            let deliveryListener: undefined | ((error: LibrdKafkaError, report: DeliveryReport) => void);
+
             try {
                 const identifier = { time: Date.now() };
                 const timer = setTimeout(() => {
@@ -89,7 +89,9 @@ export class SynchronousProducer extends AbstractProducer {
                         return;
                     }
                 };
+
                 this.on("delivery-report", deliveryListener);
+
                 await this.sendToInternalProducer(
                     key,
                     message,
@@ -103,7 +105,9 @@ export class SynchronousProducer extends AbstractProducer {
                     this.poll();
                 }, 100);
             } catch (error) {
-                this.removeListener("delivery-report", deliveryListener);
+                if (deliveryListener) {
+                    this.removeListener("delivery-report", deliveryListener);
+                }
 
                 throw KafkaError.createUnknown(error);
             }