Struct Networker

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

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 duplicate of the value.

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.