Struct SocketRpcServer 

pub struct SocketRpcServer<TSocketService, TSpawnConnection>
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, TokioSpawn<Connection<<TSocketService::SocketListener as SocketListener>::Stream, TSocketService::Codec, RpcSubmitter<TSocketService::ConnectionService>>>>

where TSocketService: SocketService, TSocketService::Codec: Send, <TSocketService::Codec as Encoder>::Serialized: Send, <TSocketService::SocketListener as SocketListener>::Stream: Send, TSocketService::ConnectionService: Send,

pub fn new( listener: TSocketService::SocketListener, socket_server: TSocketService, max_buffer_length: usize, buffer_allocation_increment: usize, max_queued_outbound_messages: usize, ) -> Result<Self>

Construct a new SocketRpcServer with a listener.

This assumes a Tokio runtime, and is only available when your SocketService is transitively Send.

impl<TSocketService, TSpawnConnection> SocketRpcServer<TSocketService, TSpawnConnection>

where TSocketService: SocketService, TSpawnConnection: Spawn<Connection<<TSocketService::SocketListener as SocketListener>::Stream, TSocketService::Codec, RpcSubmitter<TSocketService::ConnectionService>>>,

pub fn new_with_spawner( listener: TSocketService::SocketListener, socket_server: TSocketService, max_buffer_length: usize, buffer_allocation_increment: usize, max_queued_outbound_messages: usize, spawner: TSpawnConnection, ) -> Result<Self>

Construct a new SocketRpcServer with a listener and a spawner.

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, TSpawnConnection> Future for SocketRpcServer<TSocketService, TSpawnConnection>

where TSocketService: SocketService, TSpawnConnection: Spawn<Connection<<TSocketService::SocketListener as SocketListener>::Stream, TSocketService::Codec, RpcSubmitter<TSocketService::ConnectionService>>>,

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.

impl<TSocketService, TSpawnConnection> Unpin for SocketRpcServer<TSocketService, TSpawnConnection>

where TSocketService: SocketService,