[−][src]Function asyncnsq::subscribe
pub async fn subscribe(
address: Address,
handler: Arc<Box<dyn MsgHandler + Send + Sync>>,
nsq_topic: String,
nsq_channel: String,
identify_config: String
) -> Result<Reader>
a simple entry of reader to subscribe a specific nsq topic and channel