npgsql
diff --git a/‎src/Npgsql/Internal/PgBufferedConverter.cs‎
Lines changed: 2 additions & 2 deletions b/‎src/Npgsql/Internal/PgBufferedConverter.cs‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎src/Npgsql/Internal/PgReader.cs‎
Lines changed: 1 addition & 1 deletion b/‎src/Npgsql/Internal/PgReader.cs‎
Lines changed: 1 addition & 1 deletion
@@ -19,7 +19,7 @@ public sealed override T Read(PgReader reader)
     {
         // We check IsAtStart first to speed up primitive reads.
         if (!reader.IsAtStart && reader.ShouldBufferCurrent())
-            ThrowIORequired(reader.Current.BufferRequirement);
+            ThrowIORequired(reader.CurrentBufferRequirement);
 
         return ReadCore(reader);
     }
@@ -33,7 +33,7 @@ internal sealed override ValueTask<object> ReadAsObject(bool async, PgReader rea
     public sealed override void Write(PgWriter writer, T value)
     {
         if (!writer.BufferingWrite && writer.ShouldFlush(writer.CurrentBufferRequirement))
-            ThrowIORequired(writer.Current.BufferRequirement);
+            ThrowIORequired(writer.CurrentBufferRequirement);
 
         WriteCore(writer, value);
     }
 
@@ -65,7 +65,7 @@ internal PgReader(NpgsqlReadBuffer buffer)
     public ValueMetadata Current => new() { Size = CurrentSize, Format = _fieldFormat, BufferRequirement = CurrentBufferRequirement };
     public int CurrentRemaining => HasCurrent ? _currentSize - CurrentOffset : FieldRemaining;
 
-    Size CurrentBufferRequirement => HasCurrent ? _currentBufferRequirement : _fieldBufferRequirement;
+    internal Size CurrentBufferRequirement => HasCurrent ? _currentBufferRequirement : _fieldBufferRequirement;
     int CurrentOffset => FieldOffset - _currentStartPos;
 
     internal bool IsAtStart => FieldOffset is 0;
Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@ public sealed override T Read(PgReader reader)`
`19`	`19`	`{`
`20`	`20`	`// We check IsAtStart first to speed up primitive reads.`
`21`	`21`	`if (!reader.IsAtStart && reader.ShouldBufferCurrent())`
`22`		`- ThrowIORequired(reader.Current.BufferRequirement);`
	`22`	`+ ThrowIORequired(reader.CurrentBufferRequirement);`
`23`	`23`
`24`	`24`	`return ReadCore(reader);`
`25`	`25`	`}`
`@@ -33,7 +33,7 @@ internal sealed override ValueTask<object> ReadAsObject(bool async, PgReader rea`
`33`	`33`	`public sealed override void Write(PgWriter writer, T value)`
`34`	`34`	`{`
`35`	`35`	`if (!writer.BufferingWrite && writer.ShouldFlush(writer.CurrentBufferRequirement))`
`36`		`- ThrowIORequired(writer.Current.BufferRequirement);`
	`36`	`+ ThrowIORequired(writer.CurrentBufferRequirement);`
`37`	`37`
`38`	`38`	`WriteCore(writer, value);`
`39`	`39`	`}`