https://stackoverflow.com/a/78537013/1271826

TaskCancel.swift

var task: Task<Void, Error>?
let (stream, continuation) = AsyncStream.makeStream(of: URL.self)

task = Task {
    for await url in stream {
        do {
            print("Sending request to \(url)")
            let (data, response) = try await URLSession.shared.data(from: url)
            // do something with data & response

            // wait 2 seconds before getting the next URL
            try await Task.sleep(for: .seconds(2))
        } catch let error as CancellationError {
            throw error
        } catch {
            // handle network errors, but proceed iterating through the stream …
        }
    }
}

Both data(from:) and Task.sleep(…) will detect cancelation and will throw CancellationError if so, so no additional test of Task.isCancelled is needed. Probably better to just rethrow the CancellationError.