Skip to main content

run_io_loop

karyon_jsonrpc::client::multiplexed

Function run_io_loop 

Source 
async fn run_io_loop<R, Wr>(
    reader: R,
    writer: Wr,
    outbound: Receiver<Value>,
    message_dispatcher: &MessageDispatcher,
    subscriptions: &Subscriptions,
) -> Result<()>
where
    R: MessageRx<Message = Value> + Send,
    Wr: MessageTx<Message = Value> + Send,