From ce4f5a0239e4c2694d1fb239a895b3076ba82d20 Mon Sep 17 00:00:00 2001
From: Brody Robertson <bdrobert@outsidesource.com>
Date: Mon, 16 Oct 2023 12:06:53 -0400
Subject: [PATCH] Fixed Amb to manually call cancelUpstream

---
 Sources/Operators/Amb.swift | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/Sources/Operators/Amb.swift b/Sources/Operators/Amb.swift
index 5801e6c..71e692d 100644
--- a/Sources/Operators/Amb.swift
+++ b/Sources/Operators/Amb.swift
@@ -103,8 +103,10 @@ private extension Publishers.Amb {
                 guard let decision = decision else { return }
                 switch decision {
                 case .first:
+                    secondSink?.cancelUpstream()
                     secondSink = nil
                 case .second:
+                    firstSink?.cancelUpstream()
                     firstSink = nil
                 }
 
@@ -144,7 +146,9 @@ private extension Publishers.Amb {
         }
 
         func cancel() {
+            firstSink?.cancelUpstream()
             firstSink = nil
+            secondSink?.cancelUpstream()
             secondSink = nil
         }
     }