1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162 |
- export class MessageHandler {
- constructor(sourceName: any, targetName: any, comObj: any);
- sourceName: any;
- targetName: any;
- comObj: any;
- callbackId: number;
- streamId: number;
- postMessageTransfers: boolean;
- streamSinks: any;
- streamControllers: any;
- callbackCapabilities: any;
- actionHandler: any;
- _onComObjOnMessage: (event: any) => void;
- on(actionName: any, handler: any): void;
- /**
- * Sends a message to the comObj to invoke the action with the supplied data.
- * @param {string} actionName - Action to call.
- * @param {JSON} data - JSON data to send.
- * @param {Array} [transfers] - List of transfers/ArrayBuffers.
- */
- send(actionName: string, data: JSON, transfers?: any[] | undefined): void;
- /**
- * Sends a message to the comObj to invoke the action with the supplied data.
- * Expects that the other side will callback with the response.
- * @param {string} actionName - Action to call.
- * @param {JSON} data - JSON data to send.
- * @param {Array} [transfers] - List of transfers/ArrayBuffers.
- * @returns {Promise} Promise to be resolved with response data.
- */
- sendWithPromise(actionName: string, data: JSON, transfers?: any[] | undefined): Promise<any>;
- /**
- * Sends a message to the comObj to invoke the action with the supplied data.
- * Expect that the other side will callback to signal 'start_complete'.
- * @param {string} actionName - Action to call.
- * @param {JSON} data - JSON data to send.
- * @param {Object} queueingStrategy - Strategy to signal backpressure based on
- * internal queue.
- * @param {Array} [transfers] - List of transfers/ArrayBuffers.
- * @returns {ReadableStream} ReadableStream to read data in chunks.
- */
- sendWithStream(actionName: string, data: JSON, queueingStrategy: Object, transfers?: any[] | undefined): ReadableStream;
- /**
- * @private
- */
- private _createStreamSink;
- /**
- * @private
- */
- private _processStreamMessage;
- /**
- * @private
- */
- private _deleteStreamController;
- /**
- * Sends raw message to the comObj.
- * @param {Object} message - Raw message.
- * @param transfers List of transfers/ArrayBuffers, or undefined.
- * @private
- */
- private _postMessage;
- destroy(): void;
- }
|