Skip to content

Instantly share code, notes, and snippets.

View RaasAhsan's full-sized avatar

Raas Ahsan RaasAhsan

View GitHub Profile
@RaasAhsan
RaasAhsan / main.rs
Created April 24, 2022 23:14
Rust mpsc byte buffering
use std::sync::mpsc::{sync_channel, Receiver, SyncSender};
use std::thread;
enum Message {
Chunk(Vec<u8>),
Flush,
}
struct TxWrite {
tx: SyncSender<Message>,