observable-operators - npm Package Compare versions

Comparing version 1.2.2 to 1.3.0

lib/debounce.js

@@ -8,7 +8,7 @@ 'use strict';
  * [Debounces](https://davidwalsh.name/javascript-debounce-function) an Observable stream
- * by a specified number of milliseconds
+ * by a specified number of milliseconds.
  *
- * @param  {[type]} input [description]
- * @param  {[type]} ms    [description]
- * @return {[type]}       [description]
+ * @param  {Observable} input Input Observable
+ * @param  {number}     ms    Milliseconds to debounce by
+ * @return {Observable} Debounced Observable
  */
@@ -19,3 +19,3 @@ var debounce = function debounce(input, ms) {
 
-  return new Observable(function (observer) {
+  return new input.constructor(function (observer) {
     var subscription = input.subscribe({
@@ -22,0 +22,0 @@ next: function next(value) {

lib/index.js

@@ -6,3 +6,3 @@ 'use strict';
 });
-exports.transform = exports.toArray = exports.take = exports.scan = exports.reduce = exports.merge = exports.map = exports.interval = exports.fromPromise = exports.fromEvent = exports.forEach = exports.filter = exports.defer = exports.addOperators = exports.addAll = exports.default = undefined;
+exports.transform = exports.toArray = exports.take = exports.scan = exports.reduce = exports.merge = exports.map = exports.interval = exports.fromPromise = exports.fromEvent = exports.forEach = exports.filter = exports.defer = exports.debounce = exports.addOperators = exports.addAll = exports.default = undefined;
 
@@ -17,2 +17,6 @@ var _addOperators = require('./addOperators');
 
+var _debounce = require('./debounce');
+
+var _debounce2 = _interopRequireDefault(_debounce);
+
 var _defer = require('./defer');
@@ -77,3 +81,3 @@
 
-  (0, _addOperators2.default)(target.prototype, [_filter2.default, _forEach2.default, _map2.default, _merge2.default, _reduce2.default, _scan2.default, _take2.default, _toArray2.default, _transform2.default]);
+  (0, _addOperators2.default)(target.prototype, [_debounce2.default, _filter2.default, _forEach2.default, _map2.default, _merge2.default, _reduce2.default, _scan2.default, _take2.default, _toArray2.default, _transform2.default]);
 };
@@ -84,2 +88,3 @@
 exports.addOperators = _addOperators2.default;
+exports.debounce = _debounce2.default;
 exports.defer = _defer2.default;
@@ -86,0 +91,0 @@ exports.filter = _filter2.default;

package.json

 {
   "name": "observable-operators",
-  "version": "1.2.2",
+  "version": "1.3.0",
   "main": "lib/index.js",
@@ -5,0 +5,0 @@ "module": "src/index.js",

src/index.js

 import addOperators from './addOperators'
 import addCreators from './addCreators'
 
+import debounce from './debounce'
 import defer from './defer'
@@ -22,2 +23,3 @@ import filter from './filter'
   addOperators(target.prototype, [
+    debounce,
     filter,
@@ -39,2 +41,3 @@ forEach,
   addOperators,
+  debounce,
   defer,
@@ -41,0 +44,0 @@ filter,

No alert changes

Improved metrics

Total package byte prevSize

67231

increased by5.17%

Number of package files

64

increased by3.23%

Lines of code

1869

increased by5.89%

No dependency changes