Do not force flush when ODataUtf8JsonWriter buffer threshold is reach…

…ed (#3102)
OData · Oct 30, 2024 · 1848964 · 1848964
1 parent b84465b
commit 1848964
Show file tree

Hide file tree

Showing 5 changed files with 155 additions and 80 deletions.
diff --git a/src/Microsoft.OData.Core/Json/ODataUtf8JsonWriter.Stream.cs b/src/Microsoft.OData.Core/Json/ODataUtf8JsonWriter.Stream.cs
@@ -83,7 +83,7 @@ public async Task EndStreamValueScopeAsync()
                 this.binaryValueStream = null;
             }
 
-            await this.FlushIfBufferThresholdReachedAsync().ConfigureAwait(false);
+            await this.DrainBufferIfThresholdReachedAsync().ConfigureAwait(false);
 
             this.bufferWriter.Write(this.DoubleQuote.Slice(0, 1).Span);
 
@@ -282,7 +282,7 @@ private void WriteByteValueInChunks(ReadOnlySpan<byte> value)
                     }
 
                     // Flush the writer if the buffer threshold is reached
-                    this.jsonWriter.FlushIfBufferThresholdReached();
+                    this.jsonWriter.DrainBufferIfThresholdReached();
                 }
             }
 
@@ -328,7 +328,7 @@ private async ValueTask WriteByteValueInChunksAsync(ReadOnlyMemory<byte> value)
                     }
 
                     // Flush the writer if the buffer threshold is reached
-                    await this.jsonWriter.FlushIfBufferThresholdReachedAsync().ConfigureAwait(false);
+                    await this.jsonWriter.DrainBufferIfThresholdReachedAsync().ConfigureAwait(false);
                 }
             }
 

diff --git a/src/Microsoft.OData.Core/Json/ODataUtf8JsonWriter.TextWriter.cs b/src/Microsoft.OData.Core/Json/ODataUtf8JsonWriter.TextWriter.cs
@@ -119,7 +119,7 @@ public async Task EndTextWriterValueScopeAsync()
                 await this.textWriter.DisposeAsync();
             }
 
-            await this.FlushIfBufferThresholdReachedAsync().ConfigureAwait(false);
+            await this.DrainBufferIfThresholdReachedAsync().ConfigureAwait(false);
 
             CheckIfSeparatorNeeded();
             CheckIfManualValueAtArrayStart();
@@ -337,7 +337,7 @@ private void WriteCharsInChunks(ReadOnlySpan<char> value)
                     }
 
                     // Flush the writer if the buffer threshold is reached
-                    this.jsonWriter.FlushIfBufferThresholdReached();
+                    this.jsonWriter.DrainBufferIfThresholdReached();
                 }
             }
 
@@ -387,7 +387,7 @@ private async ValueTask WriteCharsInChunksAsync(ReadOnlyMemory<char> value)
                     }
 
                     // Flush the writer if the buffer threshold is reached
-                    await this.jsonWriter.FlushIfBufferThresholdReachedAsync().ConfigureAwait(false);
+                    await this.jsonWriter.DrainBufferIfThresholdReachedAsync().ConfigureAwait(false);
                 }
             }
 
@@ -431,7 +431,7 @@ private void WriteCharsInChunksWithoutEscaping(ReadOnlySpan<char> value)
                     }
 
                     // Flush the writer if the buffer threshold is reached
-                    this.jsonWriter.FlushIfBufferThresholdReached();
+                    this.jsonWriter.DrainBufferIfThresholdReached();
                 }
             }
 
@@ -475,7 +475,7 @@ private async ValueTask WriteCharsInChunksWithoutEscapingAsync(ReadOnlyMemory<ch
                     }
 
                     // Flush the writer if the buffer threshold is reached
-                    await this.jsonWriter.FlushIfBufferThresholdReachedAsync().ConfigureAwait(false);
+                    await this.jsonWriter.DrainBufferIfThresholdReachedAsync().ConfigureAwait(false);
                 }
             }