diff --git a/Sources/Rx+Combine/Observable+Combine.swift b/Sources/Rx+Combine/Observable+Combine.swift index b7d9cd3..474deda 100644 --- a/Sources/Rx+Combine/Observable+Combine.swift +++ b/Sources/Rx+Combine/Observable+Combine.swift @@ -14,10 +14,12 @@ public extension ObservableConvertibleType { /// so the Observable pushes events to the Publisher. var publisher: AnyPublisher { AnyPublisher { subscriber in + let disposable = SingleAssignmentDisposable() subscriber.receive( - subscription: RxSubscription(disposable: self.asObservable() - .subscribe(subscriber.pushRxEvent)) + subscription: RxSubscription(disposable: disposable) ) + disposable.setDisposable(self.asObservable() + .subscribe(subscriber.pushRxEvent)) } }