RXJS ^5.3.0 与 AWS JS 开发工具包

Question

我正在尝试在 AWS JS SDK 中将 RxJS Observable 添加到 s3.upload()。以下是我的代码。 请注意，我使用的是 RXJS 版本 ^5.3.0。

const s3Config = {
        Key: logoName,
        Bucket: bucketName,
        Body: files[0],
        ACL: 'public-read'
      };

      const s3Upload = s3.upload(s3Config);
      const upload$ = Observable.bindNodeCallback(s3Upload.send, s3Upload);
      upload$.subscribe(
        (value) => console.dir('Yeah !' + value),
        (err) => console.dir(err)
      );

如何绑定 Observable 和 S3.upload 方法？请帮帮我！

Answer 1

bindNodeCallback 返回一个返回 observable 的函数。并且该函数应该传递每个通常会传递给绑定函数的非回调参数。

此外，您很可能需要使用bind 来确保upload 方法绑定到s3。

我会这样做：

const upload = Observable.bindNodeCallback(s3.upload.bind(s3))

const upload$ = upload({
  Key: logoName,
  Bucket: bucketName,
  Body: files[0],
  ACL: 'public-read'
});

upload$.subscribe(
  data => console.dir(data),
  err => console.dir(err)
);