Remove unnecessary consume

FranzBusch · FranzBusch · commit 346845e1e8f0 · 2025-11-19T00:01:55.000+01:00
diff --git a/Sources/AsyncAlgorithms/MultiProducerSingleConsumerChannel/MultiProducerSingleConsumerAsyncChannel+Internal.swift b/Sources/AsyncAlgorithms/MultiProducerSingleConsumerChannel/MultiProducerSingleConsumerAsyncChannel+Internal.swift
@@ -267,7 +267,7 @@ extension MultiProducerSingleConsumerAsyncChannel {
         return $0.send(sequence)
       }
 
-      switch consume action {
+      switch action {
       case .returnProduceMore:
         return .produceMore
 
@@ -438,7 +438,7 @@ extension MultiProducerSingleConsumerAsyncChannel {
             $0.suspendNext(continuation: continuation)
           }
 
-          switch consume action {
+          switch action {
           case .resumeConsumerWithElement(let continuation, let element):
             continuation.resume(returning: element.take())
 

Original file line number	Diff line number	Diff line change
`@@ -267,7 +267,7 @@ extension MultiProducerSingleConsumerAsyncChannel {`
`267`	`267`	`return $0.send(sequence)`
`268`	`268`	`}`
`269`	`269`
`270`		`- switch consume action {`
	`270`	`+ switch action {`
`271`	`271`	`case .returnProduceMore:`
`272`	`272`	`return .produceMore`
`273`	`273`
`@@ -438,7 +438,7 @@ extension MultiProducerSingleConsumerAsyncChannel {`
`438`	`438`	`$0.suspendNext(continuation: continuation)`
`439`	`439`	`}`
`440`	`440`
`441`		`- switch consume action {`
	`441`	`+ switch action {`
`442`	`442`	`case .resumeConsumerWithElement(let continuation, let element):`
`443`	`443`	`continuation.resume(returning: element.take())`
`444`	`444`