diff --git a/rainfallwrangler/src/lib/record/RecordsWriter.mjs b/rainfallwrangler/src/lib/record/RecordsWriter.mjs
index cc5c6b1..ef839ba 100644
--- a/rainfallwrangler/src/lib/record/RecordsWriter.mjs
+++ b/rainfallwrangler/src/lib/record/RecordsWriter.mjs
@@ -21,8 +21,8 @@ class RecordsWriter {
 	}
 	
 	async close() {
-		await this.#gzip.close();
-		await this.#stream_out.close();
+		await end_safe(this.#gzip);
+		await end_safe(this.#stream_out);
 	}
 }