diff --git a/Sources/Rx+Combine/RxSubscription.swift b/Sources/Rx+Combine/RxSubscription.swift
index 3d91787..125b33f 100644
--- a/Sources/Rx+Combine/RxSubscription.swift
+++ b/Sources/Rx+Combine/RxSubscription.swift
@@ -19,7 +19,8 @@ class RxSubscription<Upstream: ObservableConvertibleType, Downstream: Subscriber
     init(upstream: Upstream,
          downstream: Downstream) {
         buffer = DemandBuffer(subscriber: downstream)
-        disposable = upstream.asObservable().subscribe(bufferRxEvents)
+        disposable = upstream.asObservable()
+            .subscribe { [unowned self] in self.bufferRxEvents($0) }
     }
 
     private func bufferRxEvents(_ event: RxSwift.Event<Upstream.Element>) {