From 7015c9347b564c0f92f651530e5acd0f45b1e35b Mon Sep 17 00:00:00 2001
From: Misha Gorshkov <mimigo98@gmail.com>
Date: Sun, 11 Dec 2022 13:26:09 +0400
Subject: [PATCH] Fixed RxSubscription strong reference cycle

---
 Sources/Rx+Combine/RxSubscription.swift | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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>) {