Struct netty_rs::Networker

pub struct Networker<T: NetworkContent + 'static, E: HandlerError> { /* fields omitted */ }

This struct is the main API for using netty. It allows the creation of a server and the ability to send messages to clients.

Implementations

impl<T: NetworkContent, E: HandlerError> Networker<T, E>

pub async fn new<H, M, FH, FM>(
    address: SocketAddr,
    directory_service: impl DirectoryService<String, E> + 'static,
    handle_handshakes: H,
    handle_messages: M
) -> Result<Networker<T, E>, Error<E>> where
    FM: Future<Output = Result<(), Error<E>>> + Send,
    FH: Future<Output = Result<String, Error<E>>> + Send,
    M: FnMut(NetworkMessage<T>, Connection<T, E>) -> FM + Send + Sync + Clone + 'static,
    H: FnMut(NetworkMessage<T>, Connection<T, E>) -> FH + Send + Sync + Clone + 'static, 

Creates a new networker using. address is the network socket address that the server should listen to. directory_service is the directory service to use in order to translate IDs to addresses. handle_handshakes is a closure that is called when a new connection is recieved which sends a NetworkMessage. This closure should authenticate if appropriate and do other handshake and setup related things. handle_messages is a closure that is called for all messages received from a connection that has already been handshaked.

pub async fn send_message(
    &self,
    message: NetworkMessage<T>,
    timeout: Option<Duration>,
    react: Option<Action<T, E>>
) -> Result<(), Error<E>>

Sends a message and then reacts to the response with the action and then returns the last message returned

pub async fn listen(&self, should_listen: bool) -> Result<(), Error<E>>

Starts the server

Trait Implementations

impl<T: Clone + NetworkContent + 'static, E: Clone + HandlerError> Clone for Networker<T, E>

fn clone(&self) -> Networker<T, E>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug + NetworkContent + 'static, E: Debug + HandlerError> Debug for Networker<T, E>

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

Formats the value using the given formatter.