Struct de_connector_lib::game::greceiver::GameProcessor

pub(super) struct GameProcessor {
    port: u16,
    owner: SocketAddr,
    messages: Receiver<InMessage<ToGame>>,
    outputs: Sender<OutPackage>,
    state: GameState,
    clients: Clients,
}

Fields

port: u16

owner: SocketAddr

messages: Receiver<InMessage<ToGame>>

outputs: Sender<OutPackage>

state: GameState

clients: Clients

Implementations

impl GameProcessor

pub(super) fn new( port: u16, owner: SocketAddr, messages: Receiver<InMessage<ToGame>>, outputs: Sender<OutPackage>, state: GameState, clients: Clients ) -> Self

pub(super) async fn run(self)

async fn handle_ignore(&self, message: &InMessage<ToGame>) -> bool

Returns true if the massage should be ignored and further handles such messages.

async fn process_ping(&self, meta: MessageMeta, id: u32)

Process a ping message.

async fn process_join(&mut self, meta: MessageMeta)

Process connect message.

async fn join(&mut self, addr: SocketAddr) -> Result<(), JoinErrorInner>

async fn process_leave(&mut self, meta: MessageMeta)

Process disconnect message.

async fn process_readiness(&mut self, meta: MessageMeta, readiness: Readiness)

async fn send_all<E>( &self, message: &E, reliability: Reliability, exclude: Option<SocketAddr> )

where E: Encode,

Send a reliable message to all players of the game.

Arguments

• message - message to be sent.

• reliability - reliability mode for the message.

• exclude - if not None, the message will be delivered to all but this player.

async fn send<E>( &self, message: &E, reliability: Reliability, target: SocketAddr )

where E: Encode,