Meet npm Pro: unlimited public & private packages + package-based permissions.Learn more »

callbag-remember

1.0.4 • Public • Published

callbag-remember

Callbag operator which shares input stream between subscribers and emits last emitted value upon subscription. It behaves pretty much as Rx's .shareReplay(1).

Example

import fromEvent from 'callbag-from-event'
import forEach from 'callbag-for-each'
import map from 'callbag-map'
import merge from 'callbag-merge'
import pipe from 'callbag-pipe'
import remember from 'callbag-remember'
 
const focus$ = remember(
  merge(
    map(() => false)(fromEvent(window, 'blur')),
    map(() => true)(fromEvent(window, 'focus')),
  ),
)
 
pipe(
  focus$,
  forEach(tabFocused => {
    // ...
  }),
)
 
// ...
 
setTimeout(() => {
  pipe(
    focus$,
    forEach(tabFocused => {
      // ... will get last emitted value immediately
    }),
  )
}, 1000)

Install

npm i callbag-remember

DownloadsWeekly Downloads

655

Version

1.0.4

License

MIT

Unpacked Size

5.09 kB

Total Files

4

Last publish

Collaborators

  • avatar