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

            let observer = AnonymousObserver { e in
                on(e)
            }
            return self.subscribeSafe(observer)
    }
    
    

    }
}

