javascript 简化的背压减轻

Posted 2021-05-03

subject
.pipe(
  // long processing
)
.subscribe(() => {
  const {
    done,
    value,
  } = (
    generator
    .next()
  )
  
  done
  ? (
    subject
    .complete()
  )
  : (
    subject
    .next(value)
  )
})

subject
.next(
  generator
  .next()
  .value
)