Struct rustdtp::ClientEventCallbacks

pub struct ClientEventCallbacks<R>
where
    R: DeserializeOwned + Send + 'static,
{ /* private fields */ }

Configuration for a client’s event callbacks.

Events

There are two events for which callbacks can be registered:

• receive
• disconnect

Both callbacks are optional, and can be registered for any combination of these events. Note that each callback must be provided as a function or closure returning a thread-safe future. The future will be awaited by the runtime.

Example

let client = Client::builder()
    .sending::<String>()
    .receiving::<usize>()
    .with_event_callbacks(
        ClientEventCallbacks::new()
            .on_receive(move |data| async move {
                // some async operation...
                println!("Received data from server: {}", data);
            })
            .on_disconnect(move || async move {
                // some async operation...
                println!("Disconnected from server");
            })
    )
    .connect(("127.0.0.1", 29275))
    .await
    .unwrap();

Implementations

impl<R> ClientEventCallbacks<R>

where R: DeserializeOwned + Send + 'static,

pub fn new() -> Self

Creates a new client event callbacks configuration with all callbacks empty.

pub fn on_receive<C, F>(self, callback: C) -> Self

where C: Fn(R) -> F + Send + 'static, F: Future<Output = ()> + Send + 'static,

Registers a callback on the receive event.

pub fn on_disconnect<C, F>(self, callback: C) -> Self

where C: Fn() -> F + Send + 'static, F: Future<Output = ()> + Send + 'static,

Registers a callback on the disconnect event.

Trait Implementations

impl<R> Default for ClientEventCallbacks<R>

where R: DeserializeOwned + Send + 'static,

fn default() -> Self

Returns the “default value” for a type.