zen-observable - npm Package Compare versions

Comparing version 0.1.8 to 0.1.9

package.json

		{
		"name": "zen-observable",
		"version": "0.1.8",
		"version": "0.1.9",
		"description": "An Implementation of ES Observables",
		@@ -8,4 +8,4 @@ "homepage": "https://github.com/zenparsing/zen-observable",
		"devDependencies": {
		"es-observable-tests": "^0.2.2"
		"es-observable-tests": "^0.2.5"
		}
		}

src/Observable.js

		@@ -151,10 +151,2 @@ // === Non-Promise Job Queueing ===

		let start = getMethod(observer, "start");

		if (start)
		start.call(observer, this);

		if (subscriptionClosed(this))
		return;

		observer = new SubscriptionObserver(this);
		@@ -309,2 +301,4 @@

		var thisArg = arguments[1];

		return new Promise((resolve, reject) => {
		@@ -319,3 +313,3 @@

		try { return fn(value) }
		try { return fn.call(thisArg, value) }
		catch (e) { reject(e) }
		@@ -322,0 +316,0 @@ },

zen-observable.js

		@@ -151,10 +151,2 @@ /=esdown=/(function(fn, name) { if (typeof exports !== 'undefined') fn(exports, module); else if (typeof self !== 'undefined') fn(name === '*' ? self : (name ? self[name] = {} : {})); })(function(exports, module) { 'use strict'; // === Non-Promise Job Queueing ===

		var start = getMethod(observer, "start");

		if (start)
		start.call(observer, this);

		if (subscriptionClosed(this))
		return;

		observer = new SubscriptionObserver(this);
		@@ -309,2 +301,4 @@

		var thisArg = arguments[1];

		return new Promise(function(resolve, reject) {
		@@ -319,3 +313,3 @@

		try { return fn(value) }
		try { return fn.call(thisArg, value) }
		catch (e) { reject(e) }
		@@ -322,0 +316,0 @@ },

New alerts