[pulsar-client-node] branch master updated: add reader listener type (#157)

[nkurihar]

This is an automated email from the ASF dual-hosted git repository.

nkurihar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git


The following commit(s) were added to refs/heads/master by this push:
     new bb4adce  add reader listener type (#157)
bb4adce is described below

commit bb4adcedfd82e7d9a9a700faf99218eece9e8ed2
Author: Yuto Furuta <mzq6mft...@gmail.com>
AuthorDate: Thu May 20 16:58:40 2021 +0900

    add reader listener type (#157)
    
    Co-authored-by: Yuto Furuta <yfur...@yahoo-corp.jp>
---
 index.d.ts | 1 +
 tstest.ts  | 8 ++++++++
 2 files changed, 9 insertions(+)

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 @@ export interface ReaderConfig {
   readerName?: string;
   subscriptionRolePrefix?: string;
   readCompacted?: boolean;
+  listener?: (message: Message, reader: Reader) => void;
 }
 
 export class Reader {
diff --git a/tstest.ts b/tstest.ts
index 2c457ba..16be59b 100644
--- a/tstest.ts
+++ b/tstest.ts
@@ -172,6 +172,13 @@ import Pulsar = require('./index');
     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 @@ import Pulsar = require('./index');
   await consumer4.close();
   await reader1.close();
   await reader2.close();
+  await reader3.close();
   await client.close();
 })();