NSQ client using core.async