Trait protosocket_server::ServerConnector

pub trait ServerConnector: Unpin {
    type Bindings: ConnectionBindings;
    type Reactor: MessageReactor<Inbound = <<Self::Bindings as ConnectionBindings>::Deserializer as Deserializer>::Message>;

    // Required methods
    fn serializer(&self) -> <Self::Bindings as ConnectionBindings>::Serializer;
    fn deserializer(
        &self,
    ) -> <Self::Bindings as ConnectionBindings>::Deserializer;
    fn new_reactor(
        &self,
        optional_outbound: Sender<<<Self::Bindings as ConnectionBindings>::Serializer as Serializer>::Message>,
    ) -> Self::Reactor;
    fn take_new_connection(
        &self,
        address: SocketAddr,
        outbound: Sender<<<Self::Bindings as ConnectionBindings>::Serializer as Serializer>::Message>,
        connection_driver: ConnectionDriver<Self::Bindings, Self::Reactor>,
    );

    // Provided methods
    fn maximum_message_length(&self) -> usize { ... }
    fn max_queued_outbound_messages(&self) -> usize { ... }
}

Required Associated Types

type Bindings: ConnectionBindings

type Reactor: MessageReactor<Inbound = <<Self::Bindings as ConnectionBindings>::Deserializer as Deserializer>::Message>

Required Methods

fn serializer(&self) -> <Self::Bindings as ConnectionBindings>::Serializer

fn deserializer(&self) -> <Self::Bindings as ConnectionBindings>::Deserializer

fn new_reactor( &self, optional_outbound: Sender<<<Self::Bindings as ConnectionBindings>::Serializer as Serializer>::Message>, ) -> Self::Reactor

fn take_new_connection( &self, address: SocketAddr, outbound: Sender<<<Self::Bindings as ConnectionBindings>::Serializer as Serializer>::Message>, connection_driver: ConnectionDriver<Self::Bindings, Self::Reactor>, )

Provided Methods

fn maximum_message_length(&self) -> usize

fn max_queued_outbound_messages(&self) -> usize

Implementors