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
23
24
25
26
27
28
29

use std::sync::Arc;

use quinn::SendStream;
use serde::Serialize;
use tokio::sync::Mutex;

use crate::common::connection::{WriteMessageError, Writer};

impl Writer for SendStream {
    async fn write_message<T: Serialize + Send>(
        &mut self,
        value: T,
    ) -> Result<(), WriteMessageError> {
        let data = postcard::to_stdvec(&value)?;
        log::debug!("wrote {} bytes", data.len());
        self.write_all(&data).await?;
        Ok(())
    }
}

impl Writer for Arc<Mutex<SendStream>> {
    async fn write_message<T: Serialize + Send>(
        &mut self,
        value: T,
    ) -> Result<(), WriteMessageError> {
        let mut lock = self.lock().await;
        SendStream::write_message(&mut *lock, value).await
    }
}