zero-trust-rps 0.0.5

Online Multiplayer Rock Paper Scissors
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use crate::common::{
    client::channel::AsyncChannelReceiver,
    connection::{WriteMessageError, Writer},
    message::ClientMessage,
};

pub async fn send_messages(
    mut conn: impl Writer,
    mut receiver: impl AsyncChannelReceiver<ClientMessage>,
) -> Result<(), WriteMessageError> {
    log::debug!("send_messages on thread {:?}", std::thread::current().id());

    while let Some(message) = receiver.receive().await {
        log::trace!(
            "Thread {:?} sending {message:?}",
            std::thread::current().id()
        );
        conn.write_message(message).await?;
    }

    Ok(())
}