Tell the delegate we stopped

vapor · Nov 3, 2023 · 975e33c · 975e33c
1 parent 7658ec6
commit 975e33c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/Sources/Vapor/Concurrency/RequestBody+Concurrency.swift b/Sources/Vapor/Concurrency/RequestBody+Concurrency.swift
@@ -146,6 +146,7 @@ extension Request.Body: AsyncSequence {
                     // The consumer dropped the sequence.
                     // Inform the producer that we don't want more data
                     // by returning an error in the future.
+                    delegate.didTerminate()
                     return request.eventLoop.makeFailedFuture(CancellationError())
                 case .stopProducing:
                     // The consumer is too slow.