import type { JSONObject } from './conmonTypes';
import type { InputData, OutputData } from './streamTypes';
export interface MessageHeaders {
    requestId: string;
    timestamp: number;
    extra: JSONObject;
}
export declare type MessagePayload = InputData | OutputData;
export declare class Message {
    payload: MessagePayload;
    headers: MessageHeaders;
    constructor(headers: MessageHeaders, payload: MessagePayload);
}
export declare class InputMessage extends Message {
    headers: MessageHeaders;
    payload: InputData;
    constructor(headers: MessageHeaders, payload: InputData);
}
export declare class OutputMessage extends Message {
    headers: MessageHeaders;
    payload: OutputData;
    constructor(headers: MessageHeaders, payload: OutputData);
}
export declare type MessageHandler<P, R> = (m: P) => R;
export declare type OnCallReturnType = void | Promise<void> | OutputData | Promise<OutputData>;
export declare type OnCallHandler = MessageHandler<InputData, OnCallReturnType>;
export declare type OnMessageReturnType = void | Promise<void> | OutputMessage | Promise<OutputMessage>;
export declare type OnMessageHandler = MessageHandler<InputMessage, OnMessageReturnType>;