diff --git a/Sources/Sunday/NetworkSession.swift b/Sources/Sunday/NetworkSession.swift
index e7db1a3e..51b3afd6 100644
--- a/Sources/Sunday/NetworkSession.swift
+++ b/Sources/Sunday/NetworkSession.swift
@@ -115,8 +115,13 @@ public class NetworkSession {
     }
 
     return AsyncThrowingStream(DataEvent.self) {
+
       let task = session.dataTask(with: request)
+
       setTaskDelegate(DataStreamDelegate(continuation: $0), for: task)
+
+      $0.onTermination = { _ in task.cancel() }
+
       task.resume()
     }