Function write_frame

nodedb/tests/native_protocol.rs:225–230

Write a length-prefixed frame payload to the stream.

(stream: &mut TcpStream, payload: &[u8])

/// Write a length-prefixed frame payload to the stream.
async fn write_frame(stream: &mut TcpStream, payload: &[u8]) {
    let len = (payload.len() as u32).to_be_bytes();
    stream.write_all(&len).await.expect("write len");
    stream.write_all(payload).await.expect("write payload");
    stream.flush().await.expect("flush");
}

/// Read a length-prefixed frame from the stream.
/// Returns `None` on EOF.