                     }
                 }
                 return Disposables.create(
-                    self.subscribeSafe(observer),
+                    self.asObservable().subscribe(observer),
                     disposable
                 )
             #endif

    }
}

extension ObservableType {
    /// All internal subscribe calls go through this method.
    fileprivate func subscribeSafe<O: ObserverType>(_ observer: O) -> Disposable where O.E == E {
        return self.asObservable().subscribe(observer)
    }
}

                    }
                }
                return Disposables.create(
                    self.asObservable().subscribe(observer),
                    disposable
                )
            #else
