使用listen()/await for 订阅 Stream