javascript - 在链中稍后访问变量

Question

在下面的示例中，我将获取一个用户并为该用户创建一个目录。我想简单地记录用户已创建。user在链中稍后访问变量的最佳方法是什么？

let ensureUser$ = ghUser$
  .map(u => Rx.Observable.fromPromise(createDir(u)))
  .flatMapLatest(x => x)
  .do(() => debug('created user dir'))

我想做类似的事情：

let ensureUser$ = ghUser$
  .map(u => Rx.Observable.fromPromise(createDir(u)))
  .flatMapLatest(x => x)
  .do(() => debug(`created user dir ${u}`))

Answer 1

你可以用 zip 做这样的事情，因为 zip 只有在它有所有新数据时才会返回一个新对象。

const user$ = Rx.Observable.just('ed')
const returnedArrary$ = user$.map(u=>[u]);

const source = Rx.Observable.zip(
    user$,
    returnedArrary$
  )
 .do(u=>console.log(`created user dir ${u[0]}`))
 .subscribe((x)=>console.log(x));

如果用户没有随着每个请求而改变，您可以根据需要使用LatestFrom 或 combineLatest。

Answer 2

您可以创建一个闭包来存储用户，然后使用 flatMapLatest 发出用户和目录结果：

let ensureUser$ = ghUser$
  .flatMapLatest(user => {
      return Rx.Observable.fromPromise(createDir(u))
           // Emit the directory and user information
           .map(directory => ({ directory, user }));
  })
  .do((x) => debug('created', x))