[LINT] type it dispatcher references correctly so that the API usage is not flagged by the linter

Author: aricart

nats-base-client/nats.ts

@@ -29,6 +29,7 @@ import type { RequestManyOptionsInternal } from "./request.ts";
 
 import { isRequestError } from "./msg.ts";
 import { createInbox, ErrorCode, RequestStrategy } from "./core.ts";
+import type { Dispatcher } from "./core.ts";
 
 import type {
   ConnectionOptions,
@@ -51,7 +52,7 @@ export class NatsConnectionImpl implements NatsConnection {
   options: ConnectionOptions;
   protocol!: ProtocolHandler;
   draining: boolean;
-  listeners: QueuedIterator<Status>[];
+  listeners: Dispatcher<Status>[];
 
   private constructor(opts: ConnectionOptions) {
     this.draining = false;

nats-base-client/protocol.ts

@@ -45,7 +45,6 @@ import type {
   Payload,
   Publisher,
   PublishOptions,
-  QueuedIterator,
   Request,
   Server,
   ServerInfo,
@@ -381,7 +380,7 @@ export class ProtocolHandler implements Dispatcher<ParserEvent> {
   publisher: Publisher;
   _closed: boolean;
   closed: Deferred<Error | void>;
-  listeners: QueuedIterator<Status>[];
+  listeners: QueuedIteratorImpl<Status>[];
   heartbeats: Heartbeat;
   parser: Parser;
   outMsgs: number;

nats-base-client/queued_iterator.ts

@@ -58,7 +58,7 @@ export class QueuedIteratorImpl<T> implements QueuedIterator<T>, Dispatcher<T> {
   iterClosed: Deferred<void | Error>;
   done: boolean;
   signal: Deferred<void>;
-  yields: T | CallbackFn[];
+  yields: (T | CallbackFn)[];
   filtered: number;
   pendingFiltered: number;
   ingestionFilterFn?: IngestionFilterFn<T>;
@@ -148,15 +148,15 @@ export class QueuedIteratorImpl<T> implements QueuedIterator<T>, Dispatcher<T> {
           }
           // only pass messages that pass the filter
           const ok = this.protocolFilterFn
-            ? this.protocolFilterFn(yields[i])
+            ? this.protocolFilterFn(yields[i] as T)
             : true;
           if (ok) {
             this.processed++;
             const start = Date.now();
-            yield yields[i];
+            yield yields[i] as T;
             this.time = Date.now() - start;
             if (this.dispatchedFn && yields[i]) {
-              this.dispatchedFn(yields[i]);
+              this.dispatchedFn(yields[i] as T);
             }
           } else {
             this.pendingFiltered--;