[observable] Add publishReplay operator (#121)

sanity-io · Aug 18, 2017 · 5eae3d9 · 5eae3d9
1 parent e36d5be
commit 5eae3d9
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/packages/@sanity/observable/src/SanityObservable.js b/packages/@sanity/observable/src/SanityObservable.js
@@ -15,6 +15,7 @@ const {withLatestFrom} = require('rxjs/operator/withLatestFrom')
 const {merge} = require('rxjs/operator/merge')
 const {share} = require('rxjs/operator/share')
 const {mergeMap} = require('rxjs/operator/mergeMap')
+const {publishReplay} = require('rxjs/operator/publishReplay')
 const {_catch} = require('rxjs/operator/catch')
 const {switchMap} = require('rxjs/operator/switchMap')
 const {_do} = require('rxjs/operator/do')
@@ -55,6 +56,7 @@ Object.assign(SanityObservable.prototype, {
   switchMap: switchMap,
   concatMap: concatMap,
   share,
+  publishReplay,
   debounceTime,
   distinctUntilChanged,
   withLatestFrom,

diff --git a/packages/@sanity/observable/test/exposed-api.test.js b/packages/@sanity/observable/test/exposed-api.test.js
@@ -50,6 +50,7 @@ function run(t) {
       'switchMap',
       'concatMap',
       'share',
+      'publishReplay',
       'debounceTime',
       'distinctUntilChanged',
       'withLatestFrom',