MqttOverWSProvider.d.ts

Filename	Percent	Threshold	Total	Covered	Uncovered
lib/Providers/MqttOverWSProvider.d.ts	94.12%	87.63%	102	96	6

import Observable, { ZenObservable } from 'zen-observable-ts';
import { AbstractPubSubProvider } from './PubSubProvider';
import { ProviderOptions } from '../types/Provider';
export declare function mqttTopicMatch(filter: string, topic: string): boolean;
export interface MqttProviderOptions extends ProviderOptions {
    clientId?: string;
    url?: string;
    aws_pubsub_endpoint?: string;
}
interface PahoClient {
    onMessageArrived: (params: {
        destinationName: string;
        payloadString: string;
    }) => void;
    onConnectionLost: (params: {
        errorCode: number;
    }) => void;
    connect: (params: {
        [k: string]: string | number | boolean | (() => void);
    }) => void;
    disconnect: () => void;
    isConnected: () => boolean;
    subscribe: (topic: string) => void;
    unsubscribe: (topic: string) => void;
    send(topic: string, message: string): any;
}
declare class ClientsQueue {
    private promises;
    get(clientId: string, clientFactory?: (input: string) => Promise<PahoClient | undefined>): Promise<PahoClient>;
    get allClients(): string[];
    remove(clientId: string): void;
}
export declare class MqttOverWSProvider extends AbstractPubSubProvider<MqttProviderOptions> {
    private _clientsQueue;
    private connectionState;
    private readonly connectionStateMonitor;
    private readonly reconnectionMonitor;
    constructor(options?: MqttProviderOptions);
    protected get clientId(): string;
    protected get endpoint(): string | undefined | Promise<string>;
    protected get clientsQueue(): ClientsQueue;
    protected get isSSLEnabled(): boolean;
    getProviderName(): string;
    onDisconnect({ clientId, errorCode, ...args }: {
        clientId?: string;
        errorCode?: number;
    }): void;
    newClient({ url, clientId, }: MqttProviderOptions): Promise<PahoClient>;
    protected connect(clientId: string, options?: MqttProviderOptions): Promise<PahoClient | undefined>;
    protected disconnect(clientId: string): Promise<void>;
    publish(topics: string[] | string, msg: object): Promise<void>;
    protected _topicObservers: Map<string, Set<ZenObservable.SubscriptionObserver<any>>>;
    protected _clientIdObservers: Map<string, Set<ZenObservable.SubscriptionObserver<any>>>;
    private _onMessage;
    subscribe(topics: string[] | string, options?: MqttProviderOptions): Observable<any>;
}
export {};

[{"file":"lib/Providers/MqttOverWSProvider.d.ts","line":27,"character":12,"text":"promises","kind":1},{"file":"lib/Providers/MqttOverWSProvider.d.ts","line":33,"character":12,"text":"_clientsQueue","kind":1},{"file":"lib/Providers/MqttOverWSProvider.d.ts","line":34,"character":12,"text":"connectionState","kind":1},{"file":"lib/Providers/MqttOverWSProvider.d.ts","line":35,"character":21,"text":"connectionStateMonitor","kind":1},{"file":"lib/Providers/MqttOverWSProvider.d.ts","line":36,"character":21,"text":"reconnectionMonitor","kind":1},{"file":"lib/Providers/MqttOverWSProvider.d.ts","line":53,"character":12,"text":"_onMessage","kind":1}]

TypeScript Coverage Report generated by type-coverage and typescript-coverage-report at Thu, 09 Feb 2023 16:23:08 GMT

TypeScript coverage report