import { RpcStreamRouter } from 'rpc-stream-router';

const rpcRouter = new RpcStreamRouter(rpcStream);

const result = await rpcRouter.send(payload);

export type JsonRpcRequest = {
  id: number;
  jsonrpc: string;
  method: string;
  params: any;
};

export interface IRpcStream {
  on: (event: string, listener: Listener) => void;
  write: (payload: JsonRpcRequest) => void;
}

export interface IRpcStreamRouter {
  send: (payload: JsonRpcRequest) => Promise<any>;
}