Mirror: 🎩 A tiny but capable push & pull stream library for TypeScript and Flow
Fix toObservable operator for zen-observable for unbound observer methods
+2
-2
+2
-2
src/web/Wonka_observable.re
+2
-2
src/web/Wonka_observable.re
···
88
88
(_observer: observableObserverT('a)): observableSubscriptionT => {
89
89
let next: (. 'a) => unit = [%raw
90
90
{|
91
-
(typeof _observer === 'object' ? _observer.next : _observer) || function () {}
91
+
(typeof _observer === 'object' ? _observer.next.bind(_observer) : _observer) || function () {}
92
92
|}
93
93
];
94
94
95
95
let complete: (. unit) => unit = [%raw
96
96
{|
97
-
(typeof _observer === 'object' ? _observer.complete : arguments[2]) || function () {}
97
+
(typeof _observer === 'object' ? _observer.complete.bind(_observer) : arguments[2]) || function () {}
98
98
|}
99
99
];
100
100