Struct Server 

pub struct Server {
    backend: ServerBackend,
    pub(crate) task_group: Arc<TaskGroup>,
    pub(crate) config: ServerConfig,
}

A JSON-RPC 2.0 server.

Fields

backend: ServerBackend

task_group: Arc<TaskGroup>

config: ServerConfig

Implementations

impl Server

pub(super) fn resolve_handler( &self, srvc_name: &str, method_name: &str, allow_pubsub: bool, ) -> Handler<'_>

Resolve a request to its handler. Pubsub handlers take priority. If allow_pubsub is false, only regular RPC services are checked.

pub(crate) async fn handle_request( &self, channel: Option<Arc<Channel>>, msg: Value, ) -> Response

Dispatch a JSON request. Pass None for channel when called from a context without pubsub support (HTTP/1.x and HTTP/2).

impl Server

pub(super) fn handle_quic_conn( self: &Arc<Self>, quic_conn: QuicConn, ) -> Result<()>

Accept a QUIC connection; each incoming stream is handled as an independent request.

impl Server

pub fn start(self: Arc<Self>)

pub async fn start_block(self: Arc<Self>) -> Result<()>

async fn accept_loop(self: &Arc<Self>) -> Result<()>

pub fn local_endpoint(&self) -> Result<Endpoint>

pub async fn shutdown(&self)

pub(crate) fn handle_message_conn<R, W>( self: &Arc<Self>, reader: R, writer: W, peer: Option<Endpoint>, )

where R: MessageRx<Message = Value> + Send + 'static, W: MessageTx<Message = Value> + Send + 'static,

Handle a split message connection (framed byte stream or WebSocket). Spawns a reader and writer task; the writer drains both responses and notifications.

async fn new_request( self: &Arc<Self>, queue: Arc<AsyncQueue<Value>>, channel: Arc<Channel>, msg: Value, )

pub(crate) async fn init<B, W>( config: ServerConfig, ex: Option<Executor>, byte_codec: B, ws_codec: W, ) -> Result<Arc<Self>>

where B: JsonRpcCodec, W: WsCodec,