             let observer = AnonymousObserver { e in
                 on(e)
             }
-            return self.subscribeSafe(observer)
+            return self.asObservable().subscribe(observer)
     }
     
     

                    }
                }
                return Disposables.create(
                    self.subscribeSafe(observer),
                    disposable
                )
            #endif

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