warqueen 0.4.8

Simple message based networking, non-async and non-blocking
Documentation 
1
2
3
4
5
6
7
8

use quinn::{ReadToEndError, RecvStream};

pub(crate) async fn receive_message_raw(
    stream: &mut RecvStream,
) -> Result<Vec<u8>, ReadToEndError> {
    const ONE_GIGABYTE_IN_BYTES: usize = 1073741824;
    stream.read_to_end(ONE_GIGABYTE_IN_BYTES).await
}