修改bug：stream.pipe()为异步函数，添加对其end事件的监听；