fix: Emit an error when the stream closes before any response (#111)

Author: keelerm84

Source/LDSwiftEventSource.swift

@@ -333,6 +333,17 @@ final class EventSourceDelegate: NSObject, URLSessionDataDelegate, @unchecked Se
                     return
                 }
             }
+        } else if readyState != .open {
+            // The task completed with no error, but the stream never opened -- no usable HTTP response
+            // was delivered. On Linux, libcurl terminates a 3xx redirect with an empty or missing
+            // Location exactly this way (no error, no response, no willPerformHTTPRedirection call),
+            // whereas CFNetwork surfaces it as an error. Retrying the same URL just repeats it, so
+            // report an unrecoverable error and stop instead of reconnecting forever.
+            logger.info("Connection closed before any response was received; reporting as unrecoverable")
+            handler.onError(EventSourceError(statusCode: nil, headers: [:], recoverable: false, underlyingError: nil))
+            readyState = .shutdown
+            continuation.finish()
+            return
         } else {
             logger.info("Connection unexpectedly closed.")
         }

Tests/LDSwiftEventSourceTests.swift

@@ -281,6 +281,28 @@ final class LDSwiftEventSourceTests {
         collector.cancel()
     }
 
+    @Test func closeWithoutResponseEmitsUnrecoverableError() async throws {
+        var config = EventSource.Config(url: URL(string: "http://example.com")!)
+        config.urlSessionConfiguration = sessionWithMockProtocol()
+        config.reconnectTime = 0.1
+        let es = EventSource(config: config)
+        let collector = EventCollector(es.events)
+        es.start()
+        let handler = try #require(await MockingProtocol.requested.expectEvent())
+        // Finish the request without ever sending a response. This is how libcurl (Linux) terminates a
+        // 3xx redirect whose Location is empty or missing: the task completes with no error and no
+        // response. The client must surface an unrecoverable error and stop, not reconnect forever.
+        handler.finish()
+        let error = await collector.expectError()
+        #expect(error?.statusCode == nil)
+        #expect(error?.recoverable == false)
+        // The unrecoverable error ends the stream; no reconnect attempt should follow.
+        await MockingProtocol.requested.expectNoEvent()
+        es.stop()
+        await expectFullyConsumed(collector)
+        collector.cancel()
+    }
+
     @Test func lastEventIdUpdatedByEvents() async throws {
         var config = EventSource.Config(url: URL(string: "http://example.com")!)
         config.urlSessionConfiguration = sessionWithMockProtocol()