MuxSubscription

import { MuxSubscription } from "https://raw.githubusercontent.com/nats-io/nats.deno/v1.27.0/nats-base-client/internal_mod.ts";

class MuxSubscription {

constructor();

baseInbox: string;

reqs: Map<string, Request>;

add(r: Request);

all(): Request[];

cancel(r: Request): void;

close();

dispatcher();

get(token: string): Request | undefined;

getToken(m: Msg): string | null;

handleError(isMuxPermissionError: boolean, err?: NatsError): boolean;

init(prefix?: string): string;

size(): number;

}

§Constructors

new MuxSubscription()

baseInbox: string

reqs: Map<string, Request>

add(r: Request)

all(): Request[]

cancel(r: Request): void

close()

dispatcher()

get(token: string): Request | undefined

getToken(m: Msg): string | null

handleError(isMuxPermissionError: boolean, err?: NatsError): boolean

init(prefix?: string): string

size(): number