Struct SocketRpcServer

pub struct SocketRpcServer<TSocketService>
where
    TSocketService: SocketService,
{ /* private fields */ }

A SocketRpcServer is a server future. It listens on a socket and spawns new connections, with a ConnectionService to handle each connection.

Protosockets use monomorphic messages: You can only have 1 kind of message per service. The expected way to work with this is to use prost and protocol buffers to encode messages.

The socket server hosts your SocketService. Your SocketService creates a ConnectionService for each new connection. Your ConnectionService manages one connection. It is Dropped when the connection is closed.

Implementations

impl<TSocketService> SocketRpcServer<TSocketService>

where TSocketService: SocketService,

pub async fn new( address: SocketAddr, socket_server: TSocketService, ) -> Result<Self>

Construct a new SocketRpcServer listening on the provided address.

pub fn set_max_buffer_length(&mut self, max_buffer_length: usize)

Set the maximum buffer length for connections created by this server after the setting is applied.

pub fn set_max_queued_outbound_messages( &mut self, max_queued_outbound_messages: usize, )

Set the maximum queued outbound messages for connections created by this server after the setting is applied.

Trait Implementations

impl<TSocketService> Future for SocketRpcServer<TSocketService>

where TSocketService: SocketService,

type Output = Result<(), Error>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, context: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.