publishValue

Author: mattpodwysocki

src/modular/observable/publishvalue.js

@@ -0,0 +1,19 @@
+'use strict';
+
+var multicast = require('./multicast');
+var BehaviorSubject = require('../behaviorsubject');
+
+function createBehaviorSubject(initialValue) {
+  return function fn() { return new BehaviorSubject(initialValue); };
+}
+
+module.exports = function publishValue() {
+  var source = arguments[0];
+  if (arguments.length === 3) {
+    return multicast(source, createBehaviorSubject(arguments[2]), arguments[1]);
+  } else if (arguments.length === 2) {
+    return multicast(source, new BehaviorSubject(arguments[1]));
+  } else {
+    throw new Error('Invalid arguments');
+  }
+};

src/modular/observable/share.js

@@ -0,0 +1,7 @@
+'use strict';
+
+var publish = require('./publish');
+
+module.exports = function share (source) {
+  return publish(source).refCount();
+};

src/modular/observable/sharereplay.js

@@ -0,0 +1,7 @@
+'use strict';
+
+var replay = require('./replay');
+
+module.exports = function shareReplay(source, bufferSize, windowSize, scheduler) {
+  return replay(source, null, bufferSize, windowSize, scheduler).refCount();
+};