add SepTextWriterDisposers

src/Sep/Internals/SepTextWriterDisposers.cs

@@ -0,0 +1,26 @@
+using System.IO;
+using System.Threading.Tasks;
+
+namespace nietras.SeparatedValues;
+
+interface ISepTextWriterDisposer
+{
+    void Dispose(TextWriter writer);
+    ValueTask DisposeAsync(TextWriter writer);
+}
+
+sealed class SepTextWriterDisposer : ISepTextWriterDisposer
+{
+    SepTextWriterDisposer() { }
+    public static SepTextWriterDisposer Instance { get; } = new();
+    public void Dispose(TextWriter writer) => writer.Dispose();
+    public ValueTask DisposeAsync(TextWriter writer) => writer.DisposeAsync();
+}
+
+sealed class NoopSepTextWriterDisposer : ISepTextWriterDisposer
+{
+    NoopSepTextWriterDisposer() { }
+    public static NoopSepTextWriterDisposer Instance { get; } = new();
+    public void Dispose(TextWriter writer) { }
+    public ValueTask DisposeAsync(TextWriter writer) => ValueTask.CompletedTask;
+}

src/Sep/SepWriter.IO.Async.cs

@@ -254,10 +254,9 @@ async ValueTask DisposeManagedAsync(CancellationToken cancellationToken)
         }
 
 #if SYNC
-        _disposeTextWriter(_writer);
+        _textWriterDisposer.Dispose(_writer);
 #else
-        // TODO TODO TODO !!!
-        _disposeTextWriter(_writer);
+        await _textWriterDisposer.DisposeAsync(_writer);
 #endif
         _arrayPool.Dispose();
         foreach (var col in _colNameToCol.Values)

src/Sep/SepWriter.IO.Sync.cs

@@ -254,10 +254,9 @@ async ValueTask DisposeManagedAsync(CancellationToken cancellationToken)
         }
 
 #if SYNC
-        _disposeTextWriter(_writer);
+        _textWriterDisposer.Dispose(_writer);
 #else
-        // TODO TODO TODO !!!
-        _disposeTextWriter(_writer);
+        await _textWriterDisposer.DisposeAsync(_writer);
 #endif
         _arrayPool.Dispose();
         foreach (var col in _colNameToCol.Values)

src/Sep/SepWriter.cs

@@ -21,7 +21,7 @@ public sealed partial class SepWriter : IDisposable
 #pragma warning disable CA2213 // Disposable fields should be disposed
     readonly TextWriter _writer;
 #pragma warning restore CA2213 // Disposable fields should be disposed
-    readonly Action<TextWriter> _disposeTextWriter;
+    readonly ISepTextWriterDisposer _textWriterDisposer;
     internal readonly List<(string ColName, int ColIndex)> _colNameCache = new(DefaultCapacity);
 
     // TODO: Add Stack<ColImpl> for remove/add cols when manipulating
@@ -36,7 +36,7 @@ public sealed partial class SepWriter : IDisposable
     bool _newRowActive = false;
     int _cacheIndex = 0;
 
-    internal SepWriter(SepWriterOptions options, TextWriter writer, Action<TextWriter> disposeTextWriter)
+    internal SepWriter(SepWriterOptions options, TextWriter writer, ISepTextWriterDisposer textWriterDisposer)
     {
         _sep = options.Sep;
         _cultureInfo = options.CultureInfo;
@@ -45,7 +45,7 @@ internal SepWriter(SepWriterOptions options, TextWriter writer, Action<TextWrite
         _colNotSetOption = options.ColNotSetOption;
         _escape = options.Escape;
         _writer = writer;
-        _disposeTextWriter = disposeTextWriter;
+        _textWriterDisposer = textWriterDisposer;
         Header = new(this);
     }
 

src/Sep/SepWriterExtensions.cs

@@ -61,8 +61,10 @@ public static SepWriter To(this SepWriterOptions options, TextWriter writer) =>
 
     public static SepWriter To(this SepWriterOptions options, TextWriter writer, bool leaveOpen)
     {
-        Action<TextWriter> disposeTextWriter = leaveOpen ? static w => { } : static w => w.Dispose();
+        ISepTextWriterDisposer textWriterDisposer = leaveOpen
+            ? NoopSepTextWriterDisposer.Instance
+            : SepTextWriterDisposer.Instance;
         ArgumentNullException.ThrowIfNull(writer);
-        return new SepWriter(options, writer, disposeTextWriter);
+        return new SepWriter(options, writer, textWriterDisposer);
     }
 }