We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 730d272 commit 60a9c36Copy full SHA for 60a9c36
Sources/Common/DemandBuffer.swift
@@ -43,6 +43,8 @@ class DemandBuffer<S: Subscriber> {
43
func buffer(value: S.Input) -> Subscribers.Demand {
44
precondition(self.completion == nil,
45
"How could a completed publisher sent values?! Beats me 🤷♂️")
46
+ lock.lock()
47
+ defer { lock.unlock() }
48
49
switch demandState.requested {
50
case .unlimited:
0 commit comments