Comparing version 11.5.0 to 11.6.0
@@ -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; |
(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&& |
@@ -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. |
{ | ||
"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", |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
58
6263
767402