import WebSocket from 'ws';
import { Observable } from 'rxjs';
import * as Joi from 'joi';
import { Logger } from '../logging';
declare function defaultActionSchemaByType(type: string): Joi.ObjectSchema | null;
export declare const actionStreamFromSocket: <T extends {
    type: string;
    payload: unknown;
}>(data: Observable<WebSocket.Data>, actionSchemaByType?: typeof defaultActionSchemaByType, logger?: Logger) => Observable<T>;
export {};