···

       
88
       
88
       
 
       
          (_observer: observableObserverT('a)): observableSubscriptionT => {

     

       
89
       
89
       
 
       
        let next: (. 'a) => unit = [%raw

     

       
90
       
90
       
 
       
          {|

     

       
91
       
91
       
-
       
          (typeof _observer === 'object' ? _observer.next : _observer) || function () {}

     

       
91
       
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
       
97
       
-
       
          (typeof _observer === 'object' ? _observer.complete : arguments[2]) || function () {}

     

       
97
       
97
       
+
       
          (typeof _observer === 'object' ? _observer.complete.bind(_observer) : arguments[2]) || function () {}

     

       
98
       
98
       
 
       
        |}

     

       
99
       
99
       
 
       
        ];

     

       
100
       
100