Fixed simple mistake from pr/buffer

kperryua · kperryua · commit ed1d2a04cfa3 · 2022-03-14T14:06:13.000-07:00
diff --git a/Sources/AsyncAlgorithms/AsyncBufferSequence.swift b/Sources/AsyncAlgorithms/AsyncBufferSequence.swift
@@ -78,8 +78,9 @@ actor AsyncBufferState<Input: Sendable, Output: Sendable> {
 
   func terminate() {
     terminationState = .terminal
+    var oldPending = pending
     pending = []
-    for continuation in pending {
+    for continuation in oldPending {
       continuation.resume(returning: .success(nil))
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -78,8 +78,9 @@ actor AsyncBufferState<Input: Sendable, Output: Sendable> {`
`78`	`78`
`79`	`79`	`func terminate() {`
`80`	`80`	`terminationState = .terminal`
	`81`	`+ var oldPending = pending`
`81`	`82`	`pending = []`
`82`		`- for continuation in pending {`
	`83`	`+ for continuation in oldPending {`
`83`	`84`	`continuation.resume(returning: .success(nil))`
`84`	`85`	`}`
`85`	`86`	`}`