diff --git a/Sources/Segment/Utilities/Telemetry.swift b/Sources/Segment/Utilities/Telemetry.swift
index 4836c3a..53eb0a8 100644
--- a/Sources/Segment/Utilities/Telemetry.swift
+++ b/Sources/Segment/Utilities/Telemetry.swift
@@ -89,7 +89,7 @@ public class Telemetry: Subscriber {
     private var seenErrors = [String: Int]()
     internal var started = false
     private var rateLimitEndTime: TimeInterval = 0
-    private var flushFirstError = true
+    internal var flushFirstError = true
     private var telemetryQueue = DispatchQueue(label: "telemetryQueue")
     private var updateQueue = DispatchQueue(label: "updateQueue")
     private var telemetryTimer: QueueTimer?
diff --git a/Tests/Segment-Tests/Telemetry_Tests.swift b/Tests/Segment-Tests/Telemetry_Tests.swift
index a182b33..9097fbd 100644
--- a/Tests/Segment-Tests/Telemetry_Tests.swift
+++ b/Tests/Segment-Tests/Telemetry_Tests.swift
@@ -116,6 +116,7 @@ class TelemetryTests: XCTestCase {
 
     func testHTTPException() {
         mockTelemetryHTTPClient(shouldThrow: true)
+        Telemetry.shared.flushFirstError = true
         Telemetry.shared.enable = true
         Telemetry.shared.start()
         Telemetry.shared.error(metric: Telemetry.INVOKE_METRIC, log: "log") { $0["error"] = "test" }