Skip to main content

reader_task

Function reader_task 

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