8000 GitHub - Andarist/callbag-drop-until: Starts emitting the input stream when another stream emits a value.
[go: up one dir, main page]
More Web Proxy on the site http://driver.im/
Skip to content

Andarist/callbag-drop-until

Repository files navigation

callbag-drop-until

Drop emitted values from source until provided observable emits.

Example

import dropUntil from 'callbag-drop-until'
import forEach from 'callbag-for-each'
import pipe from 'callbag-pipe'
import timer from 'callbag-timer'

pipe(
  interval(1000),
  dropUntil(timer(6000)),
  forEach(value => {
    // will log 5 6 7 8 ...
    console.log(value)
  }),
)

About

Starts emitting the input stream when another stream emits a value.

Topics

Resources

Stars

Watchers

Forks

Packages

No packages published
0