Skip to main content

reader_task

Function reader_task 

Source
async fn reader_task<R>(
    read: R,
    inbound_tx: Sender<RxJsonRpcMessage<RoleServer>>,
    outbound_tx: UnboundedSender<TxJsonRpcMessage<RoleServer>>,
)
where R: AsyncRead + Send + Unpin + 'static,