RxJS tap

前回と同じ、こちら共通関数。

function sto(x, time = 1000)  {
  const observable = new Observable(subscriber => {
    setTimeout(() => {
      subscriber.next(x)
      subscriber.complete()
    }, time);
  });
  return observable
}

function cl(x) {
  console.log(x)
}

副作用のある処理は、tapに書く。
パッと見で、とても分かりやすい。

let obs = sto(1)
let meta = 'foo'

obs.pipe(
  tap(() => {
    cl(meta) // 'foo'
    meta = 'bar'
  })
)
.subscribe(() => {
  cl(meta) // 'bar'
})