nodejs实现自定义流的方法