Trait PrefabFunctions

pub trait PrefabFunctions<'a, Arg: Send + 'a>: 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: ConnectionSuccess,
        remote: ClientServerRemote,
        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 + 'a>) -> Self;

    // Provided method
    fn new(
        server_connection_settings: ServerConnectionSettings,
        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: ConnectionSuccess, remote: ClientServerRemote, 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 + 'a>) -> Self

Provided Methods

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

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

Object Safety

This trait is not object safe.

Implementors

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

where F: FnOnce(GroupChannel, ClientServerRemote) -> 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> PrefabFunctions<'a, T> for PeerConnectionKernel<'a, F, Fut>

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

type UserLevelInputFunction = F

type SharedBundle = Shared