diff --git a/lib/network.rb b/lib/network.rb index 1694318..781cfb3 100644 --- a/lib/network.rb +++ b/lib/network.rb @@ -67,6 +67,10 @@ def post_logs(events, error_boundary) gzip << json_body response, e = post(url, gzip.close.string, @post_logs_retry_limit, 1, true, event_count) + + # Consume response body to ensure connection can be closed. + response&.flush + unless e == nil message = "Failed to log #{event_count} events after #{@post_logs_retry_limit} retries" puts "[Statsig]: #{message}"