Skip to content
This repository was archived by the owner on Apr 20, 2018. It is now read-only.

Commit cc1491a

Browse files
mattpodwysockimattpodwysocki
committed
Fixing Issue #652 
1 parent 7c9d40b commit cc1491a

34 files changed

Lines changed: 163 additions & 2275 deletions

‎dist/rx.all.compat.js‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -9765,32 +9765,32 @@
97659765
observableProto.transduce = function(transducer) {
97669766
var source = this;
97679767

9768-
function transformForObserver(observer) {
9768+
function transformForObserver(o) {
97699769
return {
9770-
init: function() {
9771-
return observer;
9770+
'@@transducer/init': function() {
9771+
return o;
97729772
},
9773-
step: function(obs, input) {
9773+
'@@transducer/step': function(obs, input) {
97749774
return obs.onNext(input);
97759775
},
9776-
result: function(obs) {
9776+
'@@transducer/result': function(obs) {
97779777
return obs.onCompleted();
97789778
}
97799779
};
97809780
}
97819781

9782-
return new AnonymousObservable(function(observer) {
9783-
var xform = transducer(transformForObserver(observer));
9782+
return new AnonymousObservable(function(o) {
9783+
var xform = transducer(transformForObserver(o));
97849784
return source.subscribe(
97859785
function(v) {
97869786
try {
9787-
xform.step(observer, v);
9787+
xform['@@transducer/step'](o, v);
97889788
} catch (e) {
9789-
observer.onError(e);
9789+
o.onError(e);
97909790
}
97919791
},
9792-
observer.onError.bind(observer),
9793-
function() { xform.result(observer); }
9792+
function (e) { o.onError(e); },
9793+
function() { xform['@@transducer/result'](o); }
97949794
);
97959795
}, source);
97969796
};

‎dist/rx.all.compat.map‎

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎dist/rx.all.compat.min.js‎

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎dist/rx.all.js‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -9439,32 +9439,32 @@
94399439
observableProto.transduce = function(transducer) {
94409440
var source = this;
94419441

9442-
function transformForObserver(observer) {
9442+
function transformForObserver(o) {
94439443
return {
9444-
init: function() {
9445-
return observer;
9444+
'@@transducer/init': function() {
9445+
return o;
94469446
},
9447-
step: function(obs, input) {
9447+
'@@transducer/step': function(obs, input) {
94489448
return obs.onNext(input);
94499449
},
9450-
result: function(obs) {
9450+
'@@transducer/result': function(obs) {
94519451
return obs.onCompleted();
94529452
}
94539453
};
94549454
}
94559455

9456-
return new AnonymousObservable(function(observer) {
9457-
var xform = transducer(transformForObserver(observer));
9456+
return new AnonymousObservable(function(o) {
9457+
var xform = transducer(transformForObserver(o));
94589458
return source.subscribe(
94599459
function(v) {
94609460
try {
9461-
xform.step(observer, v);
9461+
xform['@@transducer/step'](o, v);
94629462
} catch (e) {
9463-
observer.onError(e);
9463+
o.onError(e);
94649464
}
94659465
},
9466-
observer.onError.bind(observer),
9467-
function() { xform.result(observer); }
9466+
function (e) { o.onError(e); },
9467+
function() { xform['@@transducer/result'](o); }
94689468
);
94699469
}, source);
94709470
};

‎dist/rx.all.map‎

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎dist/rx.all.min.js‎

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎dist/rx.compat.js‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -4984,32 +4984,32 @@
49844984
observableProto.transduce = function(transducer) {
49854985
var source = this;
49864986

4987-
function transformForObserver(observer) {
4987+
function transformForObserver(o) {
49884988
return {
4989-
init: function() {
4990-
return observer;
4989+
'@@transducer/init': function() {
4990+
return o;
49914991
},
4992-
step: function(obs, input) {
4992+
'@@transducer/step': function(obs, input) {
49934993
return obs.onNext(input);
49944994
},
4995-
result: function(obs) {
4995+
'@@transducer/result': function(obs) {
49964996
return obs.onCompleted();
49974997
}
49984998
};
49994999
}
50005000

5001-
return new AnonymousObservable(function(observer) {
5002-
var xform = transducer(transformForObserver(observer));
5001+
return new AnonymousObservable(function(o) {
5002+
var xform = transducer(transformForObserver(o));
50035003
return source.subscribe(
50045004
function(v) {
50055005
try {
5006-
xform.step(observer, v);
5006+
xform['@@transducer/step'](o, v);
50075007
} catch (e) {
5008-
observer.onError(e);
5008+
o.onError(e);
50095009
}
50105010
},
5011-
observer.onError.bind(observer),
5012-
function() { xform.result(observer); }
5011+
function (e) { o.onError(e); },
5012+
function() { xform['@@transducer/result'](o); }
50135013
);
50145014
}, source);
50155015
};

‎dist/rx.compat.map‎

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎dist/rx.compat.min.js‎

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎dist/rx.js‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -4793,32 +4793,32 @@
47934793
observableProto.transduce = function(transducer) {
47944794
var source = this;
47954795

4796-
function transformForObserver(observer) {
4796+
function transformForObserver(o) {
47974797
return {
4798-
init: function() {
4799-
return observer;
4798+
'@@transducer/init': function() {
4799+
return o;
48004800
},
4801-
step: function(obs, input) {
4801+
'@@transducer/step': function(obs, input) {
48024802
return obs.onNext(input);
48034803
},
4804-
result: function(obs) {
4804+
'@@transducer/result': function(obs) {
48054805
return obs.onCompleted();
48064806
}
48074807
};
48084808
}
48094809

4810-
return new AnonymousObservable(function(observer) {
4811-
var xform = transducer(transformForObserver(observer));
4810+
return new AnonymousObservable(function(o) {
4811+
var xform = transducer(transformForObserver(o));
48124812
return source.subscribe(
48134813
function(v) {
48144814
try {
4815-
xform.step(observer, v);
4815+
xform['@@transducer/step'](o, v);
48164816
} catch (e) {
4817-
observer.onError(e);
4817+
o.onError(e);
48184818
}
48194819
},
4820-
observer.onError.bind(observer),
4821-
function() { xform.result(observer); }
4820+
function (e) { o.onError(e); },
4821+
function() { xform['@@transducer/result'](o); }
48224822
);
48234823
}, source);
48244824
};

0 commit comments

Comments
 (0)