Struct jsonrpsee_ws_server::WsServer

pub struct WsServer { /* fields omitted */ }

Implementations

impl Server

pub async fn new(addr: impl ToSocketAddrs) -> Result<Self>

Create a new WebSocket RPC server, bound to the addr.

pub fn register_method<F, R>(
    &mut self,
    method_name: &'static str,
    callback: F
) -> Result<(), Error> where
    R: Serialize,
    F: Fn(RpcParams<'_>) -> Result<R, RpcError> + Send + Sync + 'static, 

Register a new RPC method, which responds with a given callback.

pub fn register_subscription(
    &mut self,
    subscribe_method_name: &'static str,
    unsubscribe_method_name: &'static str
) -> Result<SubscriptionSink, Error>

Register a new RPC subscription, with subscribe and unsubscribe methods.

pub fn register_module(&mut self, module: RpcModule) -> Result<(), Error>

Register all methods from a module on this server.

pub fn local_addr(&self) -> Result<SocketAddr>

Returns socket address to which the server is bound.

pub async fn start(self)

Start responding to connections requests. This will block current thread until the server is stopped.