[][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