import 'rxjs/add/observable/from';
import 'rxjs/add/operator/mergeAll';
import { Observable } from 'rxjs/Observable';
import { RequestEvent } from 'snapper-consumer';
import { Database } from '../db';
import { Net } from '../Net';
import { ParsedWSMsg, WSMsgHandler, WSMsgToDBHandler } from '../utils';
import { TableInfoByMessageType } from './MapToTable';
import { Proxy } from './Middleware';
export declare const createMsgHandler: (proxy?: Proxy) => (msg: ParsedWSMsg) => Observable<any>;
/**
 * refresh 事件需要逐个单独处理
 * destroy 事件没有 data
 */
export declare const createMsgToDBHandler: (mapToTable: TableInfoByMessageType) => (msg: ParsedWSMsg, db: Database) => Observable<any>;
export declare function socketHandler(net: Net, event: RequestEvent, handleMsgToDb: WSMsgToDBHandler, handleMsg: WSMsgHandler, mapToTable: TableInfoByMessageType, db?: Database): Observable<any>;