Fixed FirstMatch and Matches publisher

ragzy15 · Apr 18, 2020 · 8a4c6fa · 8a4c6fa
1 parent c95c462
commit 8a4c6fa
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/Sources/PublisherKit/Publishers/Matches/First Match.swift b/Sources/PublisherKit/Publishers/Matches/First Match.swift
@@ -85,6 +85,8 @@ extension Publishers.FirstMatch {
             guard status == .awaiting else { lock.unlock(); return }
             status = .subscribed(to: subscription)
             lock.unlock()
+
+            downstream?.receive(subscription: self)
         }
 
         func receive(_ input: String) -> Subscribers.Demand {
@@ -114,6 +116,7 @@ extension Publishers.FirstMatch {
             guard status.isSubscribed else { lock.unlock(); return }
             status = .terminated
             lock.unlock()
+
             downstream?.receive(completion: completion.eraseError())
         }
 

diff --git a/Sources/PublisherKit/Publishers/Matches/Matches.swift b/Sources/PublisherKit/Publishers/Matches/Matches.swift
@@ -85,6 +85,8 @@ extension Publishers.Matches {
             guard status == .awaiting else { lock.unlock(); return }
             status = .subscribed(to: subscription)
             lock.unlock()
+
+            downstream?.receive(subscription: self)
         }
 
         func receive(_ input: String) -> Subscribers.Demand {
@@ -114,6 +116,7 @@ extension Publishers.Matches {
             guard status.isSubscribed else { lock.unlock(); return }
             status = .terminated
             lock.unlock()
+
             downstream?.receive(completion: completion.eraseError())
         }