commit bb4adcedfd82e7d9a9a700faf99218eece9e8ed2
author Yuto Furuta <mzq6mft9zz@gmail.com> Thu May 20 16:58:40 2021 +0900
committer GitHub <noreply@github.com> Thu May 20 16:58:40 2021 +0900
tree 6104c0f367ab910be90f91068c9d57109c8a18ed
parent c261c262460f0a090729bf42db883432e42c9052

add reader listener type (#157)

Co-authored-by: Yuto Furuta <yfuruta@yahoo-corp.jp>

index.d.ts

diff --git a/index.d.ts b/index.d.ts
index adf5247..63151c3 100644
--- a/index.d.ts
+++ b/index.d.ts
@@ -107,6 +107,7 @@
   readerName?: string;
   subscriptionRolePrefix?: string;
   readCompacted?: boolean;
+  listener?: (message: Message, reader: Reader) => void;
 }
 
 export class Reader {

tstest.ts

diff --git a/tstest.ts b/tstest.ts
index 2c457ba..16be59b 100644
--- a/tstest.ts
+++ b/tstest.ts
@@ -172,6 +172,13 @@
     startMessageId: Pulsar.MessageId.earliest(),
   });
 
+  const reader3: Pulsar.Reader = await client.createReader({
+    topic: 'persistent://public/default/my-topic',
+    startMessageId: Pulsar.MessageId.earliest(),
+    listener: (message: Pulsar.Message, reader: Pulsar.Reader) => {
+    },
+  });
+
   const producerName: string = producer1.getProducerName();
   const topicName1: string = producer1.getTopic();
 
@@ -231,6 +238,7 @@
   await consumer4.close();
   await reader1.close();
   await reader2.close();
+  await reader3.close();
   await client.close();
 })();