Skip to main content

pump

Function pump 

Source
async fn pump<R: AsyncRead + Unpin>(reader: R, tx: UnboundedSender<JobEvent>)