rpc.rpcwebsocket #

Handlers

The module comes with

fn echo_handler(client &websocket.Client, msg string) !string

fn new_client(address string, logger &log.Logger) !&RpcWsClient

fn new_rpcwsclient(address string, logger &log.Logger) !&RpcWsClient

fn new_rpcwsserver(port int, handler MessageHandler, logger &log.Logger) !&RpcWsServer

struct RpcWsClient {
pub mut:
	client                    &Client
	channel_incoming_messages chan string
	logger                    &log.Logger
}

fn (mut w RpcWsClient) run() !

fn (mut w RpcWsClient) send(message string, timeout int) !string

fn (mut w RpcWsClient) send_json_rpc[T, D](method string, data T, timeout int) !D

struct RpcWsServer {
pub mut:
	server  &Server
	logger  &log.Logger
	handler MessageHandler @[required]
}

fn (mut rws RpcWsServer) run() !