pub async fn subscribe<A: ToSocketAddrs + Display>(
nsqd_addr: A,
topic: &str,
channel: &str,
ready_count: u32,
) -> Result<Arc<Connection>>Expand description
从NSQ主题订阅消息
pub async fn subscribe<A: ToSocketAddrs + Display>(
nsqd_addr: A,
topic: &str,
channel: &str,
ready_count: u32,
) -> Result<Arc<Connection>>从NSQ主题订阅消息