Struct RpcService 

pub struct RpcService { /* private fields */ }

JSON-RPC service middleware.

Implementations

impl RpcService

pub fn new( methods: Methods, max_response_body_size: usize, conn_id: ConnectionId, bounded_subscriptions: BoundedSubscriptions, sink: MethodSink, id_provider: Arc<dyn IdProvider>, ) -> Self

Creates a service for a connection that supports subscriptions.

Subscription notifications are sent to sink, and at most bounded_subscriptions of them can be active at once.

Trait Implementations

impl Clone for RpcService

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RpcService

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RpcServiceT for RpcService

fn call<'a>( &self, req: Request<'a>, ) -> impl Future<Output = MethodResponse> + Send + 'a

Processes a single JSON-RPC call, which may be a subscription or regular call.

fn batch<'a>( &self, batch: Batch<'a>, ) -> impl Future<Output = MethodResponse> + Send + 'a

Processes multiple JSON-RPC calls at once, similar to RpcServiceT::call.

fn notification<'a>( &self, _n: Notification<'a>, ) -> impl Future<Output = MethodResponse> + Send + 'a

Similar to RpcServiceT::call but processes a JSON-RPC notification.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 72 bytes