From 34913daea64e3a7cfd232ef11f9256412728d061 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Bj=C3=B8rge=20N=C3=A6ss?= <bjoerge@gmail.com>
Date: Fri, 18 Aug 2017 16:18:53 +0200
Subject: [PATCH] [observable] Add publishReplay operator (#121)

---
 packages/@sanity/observable/src/SanityObservable.js  | 2 ++
 packages/@sanity/observable/test/exposed-api.test.js | 1 +
 2 files changed, 3 insertions(+)

diff --git a/packages/@sanity/observable/src/SanityObservable.js b/packages/@sanity/observable/src/SanityObservable.js
index 69c45f615f2..cc0e0a738b6 100644
--- 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
index c05b22e0d66..fc9ad7187e7 100644
--- 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',