1 2 3 4 5 6 7
use std::{io::Read, sync::mpsc::Sender}; use crate::Provider; pub(crate) trait StreamWorker<T>: Provider<T, ()> { fn worker<R: Read + Send>(input: R, tx: Sender<T>) where T: Send; }