Function grammers_mtsender::connect

pub async fn connect<T: Transport>(
    transport: T,
    addr: SocketAddr,
    rc_policy: &'static dyn ReconnectionPolicy
) -> Result<(Sender<T, Encrypted>, Enqueuer), AuthorizationError>