我使用 aws sdk for javascript 将对象上传到 S3 存储桶，但也使用反应式编程 rxjs 创建流。那么，将 S3 作为流上传然后作为流触发 API 调用的最佳方法是什么？
var stream = Rx.Observable.fromPromise(s3.putObject(params).promise());
stream.subscribe(data=>{},err=>{})
在上面的示例中，它有效，但问题是即使文件成功上传到 S3 存储桶后，“数据”也是一个空对象，因此我无法执行 API 流，因为我需要一些文件信息。
或者我应该使用 Rx.Observable.fromNodeCallback(s3.upload)？请指教，非常感谢。