Trait PrefabFunctions

pub trait PrefabFunctions<'a, Arg: Send + 'a, R: Ratchet>: Sized + 'a {
    type UserLevelInputFunction: Send + 'a;
    type SharedBundle: Send + 'a;

    // Required methods
    fn get_shared_bundle(&self) -> Self::SharedBundle;
    fn on_c2s_channel_received<'async_trait>(
        connect_success: CitadelClientServerConnection<R>,
        arg: Arg,
        fx: Self::UserLevelInputFunction,
        shared: Self::SharedBundle,
    ) -> Pin<Box<dyn Future<Output = Result<(), NetworkError>> + Send + 'async_trait>>
       where Self: 'async_trait;
    fn construct(kernel: Box<dyn NetKernel<R> + 'a>) -> Self;

    // Provided method
    fn new(
        server_connection_settings: ServerConnectionSettings<R>,
        arg: Arg,
        on_channel_received: Self::UserLevelInputFunction,
    ) -> Self { ... }
}

Required Associated Types

type UserLevelInputFunction: Send + 'a

type SharedBundle: Send + 'a

Shared between the kernel and the on_c2s_channel_received function

Required Methods

fn get_shared_bundle(&self) -> Self::SharedBundle

fn on_c2s_channel_received<'async_trait>( connect_success: CitadelClientServerConnection<R>, arg: Arg, fx: Self::UserLevelInputFunction, shared: Self::SharedBundle, ) -> Pin<Box<dyn Future<Output = Result<(), NetworkError>> + Send + 'async_trait>>

where Self: 'async_trait,

fn construct(kernel: Box<dyn NetKernel<R> + 'a>) -> Self

Provided Methods

fn new( server_connection_settings: ServerConnectionSettings<R>, arg: Arg, on_channel_received: Self::UserLevelInputFunction, ) -> Self

Creates a new connection with a central server entailed by the user information

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<'a, F, Fut, R: Ratchet> PrefabFunctions<'a, GroupInitRequestType, R> for BroadcastKernel<'a, F, Fut, R>

where F: FnOnce(GroupChannel, CitadelClientServerConnection<R>) -> Fut + Send + 'a, Fut: Future<Output = Result<(), NetworkError>> + Send + 'a,

type UserLevelInputFunction = F

type SharedBundle = Arc<BroadcastShared>

impl<'a, F, Fut, T: Into<PeerConnectionSetupAggregator> + Send + 'a, R: Ratchet> PrefabFunctions<'a, T, R> for PeerConnectionKernel<'a, F, Fut, R>

where F: FnOnce(Receiver<Result<PeerConnectSuccess<R>, NetworkError>>, CitadelClientServerConnection<R>) -> Fut + Send + 'a, Fut: Future<Output = Result<(), NetworkError>> + Send + 'a,

type UserLevelInputFunction = F

type SharedBundle = Shared