Comparing version 0.9.7 to 0.10.0
@@ -107,11 +107,11 @@ var _ = require("./_"); | ||
subscribe: function (onEmit, onError) { | ||
var self = this, child = new Observable(); | ||
child._onEmit = onEmit; | ||
child._onError = onError; | ||
child._nextErr = genNextErr(child.emit); | ||
var self = this, subscriber = new Observable(); | ||
subscriber._onEmit = onEmit; | ||
subscriber._onError = onError; | ||
subscriber._nextErr = genNextErr(subscriber.emit); | ||
child.publisher = self; | ||
self.subscribers.push(child); | ||
subscriber.publisher = self; | ||
self.subscribers.push(subscriber); | ||
return child; | ||
return subscriber; | ||
}, | ||
@@ -131,11 +131,11 @@ | ||
return self.emit = function (val) { | ||
var i = 0, len = self.subscribers.length, child; | ||
var i = 0, len = self.subscribers.length, subscriber; | ||
while (i < len) { | ||
child = self.subscribers[i++]; | ||
subscriber = self.subscribers[i++]; | ||
_.Promise.resolve(val).then( | ||
child._onEmit, | ||
child._onError | ||
subscriber._onEmit, | ||
subscriber._onError | ||
).then( | ||
child.emit, | ||
child._nextErr | ||
subscriber.emit, | ||
subscriber._nextErr | ||
); | ||
@@ -142,0 +142,0 @@ } |
/* | ||
Yaku v0.9.7 | ||
Yaku v0.10.0 | ||
(c) 2015 Yad Smood. http://ysmood.org | ||
@@ -4,0 +4,0 @@ License MIT |
{ | ||
"name": "yaku", | ||
"version": "0.9.7", | ||
"version": "0.10.0", | ||
"description": "A light-weight ES6 Promises/A+ implementation that doesn't hurt.", | ||
@@ -5,0 +5,0 @@ "main": "lib/yaku.js", |
75341