Class PubSub

new PubSub(nymphOptions: NymphOptions, nymph: Nymph): PubSub

authenticate(authToken: string | null, switchToken?: string | null): void

close(): void

connect(): void

isConnection(): boolean

isConnectionConnecting(): boolean

isConnectionOpen(): boolean

off<T extends PubSubEventType>(
    event: T,
    callback: T extends "connect"
        ? PubSubConnectCallback
        : T extends "disconnect"
            ? PubSubDisconnectCallback
            : T extends "error" ? PubSubErrorCallback : never,
): boolean

on<T extends PubSubEventType>(
    event: T,
    callback: T extends "connect"
        ? PubSubConnectCallback
        : T extends "disconnect"
            ? PubSubDisconnectCallback
            : T extends "error" ? PubSubErrorCallback : never,
): () => boolean

subscribeEntities<T extends EntityConstructor = EntityConstructor>(
    options: Options<T> & { return: "guid" },
    ...selectors: Selector[],
): PubSubSubscribable<PubSubUpdate<string[]>>

subscribeEntities<T extends EntityConstructor = EntityConstructor>(
    options: Options<T>,
    ...selectors: Selector[],
): PubSubSubscribable<PubSubUpdate<EntityInstanceType<T>[]>>

subscribeEntity<T extends EntityConstructor = EntityConstructor>(
    options: Options<T> & { return: "guid" },
    ...selectors: Selector[],
): PubSubSubscribable<PubSubUpdate<string | null>>

subscribeEntity<T extends EntityConstructor = EntityConstructor>(
    options: Options<T>,
    ...selectors: Selector[],
): PubSubSubscribable<PubSubUpdate<EntityInstanceType<T> | null>>

subscribeUID(
    name: string,
): (
    resolve?: PubSubResolveCallback<number>,
    reject?: PubSubRejectCallback,
    count?: PubSubCountCallback,
) => { unsubscribe: () => void }

subscribeWith<T extends EntityInterface>(
    entity: T,
    resolve?: PubSubResolveCallback<T>,
    reject?: PubSubRejectCallback,
    count?: PubSubCountCallback,
): PubSubSubscription<T>

updateArray(
    current: EntityInterface[],
    update: PubSubUpdate<EntityInterface[]>,
): void