Skip to main content

reader_task

futu_mcp::transport

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,