Function run_io_loop 

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