Function create_client

pub async fn create_client<A>(
    addr: A,
) -> Result<(UnboundedSender<Message>, UnboundedReceiver<Message>), Error>
where
    A: ToSocketAddrs,