Rebase fixes

src/connection.ts

@@ -129,7 +129,7 @@ export class Connection {
 
   public async declareConsumer(params: DeclareConsumerParams, handle: ConsumerFunc): Promise<Consumer> {
     const consumerId = this.incConsumerId()
-    const consumer = new Consumer(handle)
+    const consumer = new Consumer(handle, consumerId)
     this.consumers.set(consumerId, consumer)
 
     const res = await this.sendAndWait<SubscribeResponse>(
@@ -167,7 +167,7 @@ export class Connection {
   }
 
   public getConsumersNumber() {
-    return this.consumers.length
+    return this.consumers.size
   }
 
   public send(cmd: Request): Promise<void> {

src/consumer.ts

@@ -3,7 +3,7 @@ import { Message } from "./producer"
 export type ConsumerFunc = (message: Message) => void
 
 export class Consumer {
-  constructor(readonly handle: ConsumerFunc) {}
+  constructor(readonly handle: ConsumerFunc, readonly consumerId: number) {}
 
   async close(): Promise<void> {
     throw new Error("Method not implemented.")