Function subscribe 

pub async fn subscribe<F>(
    conn: &Connection,
    subject: &str,
    handler: F,
) -> Result<(), Error>
where
    F: FnMut(Vec<u8>) + Send + 'static,

Subscribe to a subject with message handler