@aws-amplify/pubsub

constructor(options: ProviderOptions);

readonly options: ProviderOptions;

configure: (config: T) => T;

getCategory: () => string;

abstract getProviderName: () => string;

abstract newClient: (clientOptions: T) => Promise<any>;

abstract publish: (
    topics: string[] | string,
    msg: PubSubContent,
    options?: T
) => void;

abstract subscribe: (
    topics: string[] | string,
    options?: T
) => Observable<PubSubContent>;

constructor(options?: ProviderOptions);

readonly isSSLEnabled: boolean;

close: () => void;

getNewWebSocket: (url: string, protocol: string) => WebSocket;

getProviderName: () => string;

newClient: () => Promise<any>;

publish: (
    _topics: string[] | string,
    _msg: PubSubContent,
    _options?: AWSAppSyncRealTimeProviderOptions
) => Promise<void>;

subscribe: (
    _topics: string[] | string,
    options?: AWSAppSyncRealTimeProviderOptions
) => Observable<Record<string, unknown>>;

constructor(options?: AWSIoTProviderOptions);

readonly endpoint: Promise<string>;

readonly region: string;

getProviderName: () => string;

constructor(options?: MqttProviderOptions);

readonly clientId: string;

readonly clientsQueue: ClientsQueue;

readonly endpoint: Promise<string>;

readonly isSSLEnabled: boolean;

protected connect: (
    clientId: string,
    options?: MqttProviderOptions
) => Promise<PahoClient | undefined>;

protected disconnect: (clientId: string) => Promise<void>;

getProviderName: () => string;

newClient: ({ url, clientId }: MqttProviderOptions) => Promise<PahoClient>;

onDisconnect: ({
    clientId,
    errorCode,
    ...args
}: {
    clientId?: string;
    errorCode?: number;
}) => void;

publish: (topics: string[] | string, msg: PubSubContent) => Promise<void>;

subscribe: (
    topics: string[] | string,
    options?: MqttProviderOptions
) => Observable<PubSubContent>;

additionalHeaders?: {
    [key: string]: string;
};

apiKey?: string;

appSyncGraphqlEndpoint?: string;

authenticationType?: GraphqlAuthModes;

graphql_headers?: () => {} | (() => Promise<{}>);

query?: string;

region?: string;

variables?: Record<string, unknown>;

aws_pubsub_endpoint?: string;

aws_pubsub_region?: string;

aws_pubsub_endpoint?: string;

clientId?: string;

url?: string;

Connected = 'Connected'

ConnectedPendingDisconnect = 'ConnectedPendingDisconnect'

ConnectedPendingKeepAlive = 'ConnectedPendingKeepAlive'

ConnectedPendingNetwork = 'ConnectedPendingNetwork'

Connecting = 'Connecting'

ConnectionDisrupted = 'ConnectionDisrupted'

ConnectionDisruptedPendingNetwork = 'ConnectionDisruptedPendingNetwork'

Disconnected = 'Disconnected'

CONNECTION_CLOSED = 'Connection closed'

CONNECTION_FAILED = 'Connection failed'

REALTIME_SUBSCRIPTION_INIT_ERROR = 'AppSync Realtime subscription init error'

SUBSCRIPTION_ACK = 'Subscription ack'

TIMEOUT_DISCONNECT = 'Timeout disconnect'