xstream - npm Package Compare versions

Comparing version 11.5.0 to 11.6.0

dist/xstream.js

@@ -61,3 +61,3 @@ (function(f){if(typeof exports==="object"&&typeof module!=="undefined"){module.exports=f()}else if(typeof define==="function"&&define.amd){define([],f)}else{var g;if(typeof window!=="undefined"){g=window}else if(typeof global!=="undefined"){g=global}else if(typeof self!=="undefined"){g=self}else{g=this}g.xstream = f()}})(function(){var define,module,exports;return (function(){function r(e,n,t){function o(i,f){if(!n[i]){if(!e[i]){var c="function"==typeof require&&require;if(!f&&c)return c(i,!0);if(u)return u(i,!0);var a=new Error("Cannot find module '"+i+"'");throw a.code="MODULE_NOT_FOUND",a}var p=n[i]={exports:{}};e[i][0].call(p.exports,function(r){var n=e[i][1][r];return o(n||r)},p,p.exports,r,e,n,t)}return n[i].exports}for(var u="function"==typeof require&&require,i=0;i<t.length;i++)o(t[i]);return o}return r})()({1:[function(require,module,exports){
     StreamSub.prototype.unsubscribe = function () {
-        this._stream.removeListener(this._listener);
+        this._stream._remove(this._listener);
     };
@@ -64,0 +64,0 @@ return StreamSub;

dist/xstream.min.js

 (function(e){"object"===typeof exports&&"undefined"!==typeof module?module.exports=e():"function"===typeof define&&define.amd?define([],e):("undefined"!==typeof window?window:"undefined"!==typeof global?global:"undefined"!==typeof self?self:this).xstream=e()})(function(){return function(){function e(k,h,d){function q(l,m){if(!h[l]){if(!k[l]){var n="function"==typeof require&&require;if(!m&&n)return n(l,!0);if(u)return u(l,!0);m=Error("Cannot find module '"+l+"'");throw m.code="MODULE_NOT_FOUND",m;
 }m=h[l]={exports:{}};k[l][0].call(m.exports,function(c){return q(k[l][1][c]||c)},m,m.exports,e,k,h,d)}return h[l].exports}for(var u="function"==typeof require&&require,n=0;n<d.length;n++)q(d[n]);return q}return e}()({1:[function(e,k,h){function d(){}function q(a){for(var b=a.length,f=Array(b),c=0;c<b;++c)f[c]=a[c];return f}function u(a,b){return function(f){return a(f)&&b(f)}}function n(a,b,f){try{return a.f(b)}catch(g){return f._e(g),c}}function l(a){a._start=function(b){b.next=b._n;b.error=b._e;
 b.complete=b._c;this.start(b)};a._stop=a.stop}var m=this&&this.__extends||function(){var a=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(b,f){b.__proto__=f}||function(b,f){for(var a in f)f.hasOwnProperty(a)&&(b[a]=f[a])};return function(b,f){function c(){this.constructor=b}a(b,f);b.prototype=null===f?Object.create(f):(c.prototype=f.prototype,new c)}}();Object.defineProperty(h,"__esModule",{value:!0});var t=e("symbol-observable"),c={};h.NO=c;var r={_n:d,_e:d,_c:d};h.NO_IL=r;var x=
-function(){function a(b,f){this._stream=b;this._listener=f}a.prototype.unsubscribe=function(){this._stream.removeListener(this._listener)};return a}(),y=function(){function a(b){this._listener=b}a.prototype.next=function(b){this._listener._n(b)};a.prototype.error=function(b){this._listener._e(b)};a.prototype.complete=function(){this._listener._c()};return a}(),z=function(){function a(b){this.type="fromObservable";this.ins=b;this.active=!1}a.prototype._start=function(b){this.out=b;this.active=!0;this._sub=
+function(){function a(b,f){this._stream=b;this._listener=f}a.prototype.unsubscribe=function(){this._stream._remove(this._listener)};return a}(),y=function(){function a(b){this._listener=b}a.prototype.next=function(b){this._listener._n(b)};a.prototype.error=function(b){this._listener._e(b)};a.prototype.complete=function(){this._listener._c()};return a}(),z=function(){function a(b){this.type="fromObservable";this.ins=b;this.active=!1}a.prototype._start=function(b){this.out=b;this.active=!0;this._sub=
 this.ins.subscribe(new y(b));this.active||this._sub.unsubscribe()};a.prototype._stop=function(){this._sub&&this._sub.unsubscribe();this.active=!1};return a}(),A=function(){function a(b){this.type="merge";this.insArr=b;this.out=c;this.ac=0}a.prototype._start=function(b){this.out=b;b=this.insArr;var f=b.length;this.ac=f;for(var a=0;a<f;a++)b[a]._add(this)};a.prototype._stop=function(){for(var b=this.insArr,a=b.length,g=0;g<a;g++)b[g]._remove(this);this.out=c};a.prototype._n=function(b){var a=this.out;
@@ -6,0 +6,0 @@ a!==c&&a._n(b)};a.prototype._e=function(b){var a=this.out;a!==c&&a._e(b)};a.prototype._c=function(){if(0>=--this.ac){var b=this.out;b!==c&&b._c()}};return a}(),C=function(){function a(b,a,c){this.i=b;this.out=a;this.p=c;c.ils.push(this)}a.prototype._n=function(b){var a=this.p,g=this.out;if(g!==c&&a.up(b,this.i)){b=a.vals;a=b.length;for(var w=Array(a),d=0;d<a;++d)w[d]=b[d];g._n(w)}};a.prototype._e=function(b){var a=this.out;a!==c&&a._e(b)};a.prototype._c=function(){var b=this.p;b.out!==c&&0===--b.Nc&&

index.d.ts

@@ -106,3 +106,3 @@ declare const NO: {};
      */
-    subscribe(listener: Listener<T>): Subscription;
+    subscribe(listener: Partial<Listener<T>>): Subscription;
     /**
@@ -109,0 +109,0 @@ * Creates a new Stream given a Producer.

package.json

 {
   "name": "xstream",
-  "version": "11.5.0",
+  "version": "11.6.0",
   "description": "An extremely intuitive, small, and fast functional reactive stream library for JavaScript",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Number of package files

58

increased by1.75%

Lines of code

6263

increased by0.05%

Worsened metrics

Total package byte prevSize

767402

decreased by-13.05%

No dependency changes