import { IStreamModel, JSONValue, RequestHandler, ServiceHandler, StreamHandler } from '../util/types'; import { Model } from './model'; export declare class IgnoreStreamEventException extends Error { constructor(msg: string); } export declare class Stream extends Model { #private; static endpoint: string; websocketUrl: string; websocketService: string; constructor(service?: string, startWatchdog?: boolean); reset(): void; close(): void; subscribe(model: IStreamModel, full?: boolean): Promise; unsubscribe(model: IStreamModel): Promise; subscribeInternal(type: string, handler: RequestHandler): Promise; subscribeService(service: string, handler: ServiceHandler, full?: boolean): Promise; unsubscribeService(service: string, handler: ServiceHandler, full?: boolean): Promise; subscribeEvent(service: string, handler: StreamHandler): Promise; unsubscribeEvent(service: string, handler: StreamHandler): Promise; sendEvent(type: string, msg: JSONValue): Promise; sendRequest(msg: JSONValue): Promise; onRequest(handler: RequestHandler, internal: boolean): Promise; cancelRequest(handler: RequestHandler, internal: boolean): Promise; }