From 26be776ef8afe1a21f6c47daaa99b035799fa4c5 Mon Sep 17 00:00:00 2001 From: utf Date: Sat, 30 Dec 2023 12:42:17 +0100 Subject: [PATCH] feat(client): add close() method to server --- src/Client.js | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/Client.js b/src/Client.js index 00f5e12..833d39c 100644 --- a/src/Client.js +++ b/src/Client.js @@ -187,14 +187,17 @@ export class Client extends EventEmitter { } listen(port, callback) { - this.on('raw', container => { + const listener = container => { if(container.message === 'Message') { const message = Message.toObject(container.Message, { longs: String }) callback(BigInt(message.address), message.data) } - }) + } + + this.on('raw', listener) return { + close: () => this.removeListener('raw', listener), publish: flags => this.#publish(port, flags), unpublish: flags => this.#unpublish(port) }