Class PgWriter
public sealed class PgWriter
- Inheritance
-
PgWriter
- Inherited Members
Properties
Current
public ValueMetadata Current { get; }
Property Value
Methods
BeginNestedWrite(Size, int, object?)
public NestedWriteScope BeginNestedWrite(Size bufferRequirement, int byteCount, object? state)
Parameters
Returns
BeginNestedWriteAsync(Size, int, object?, CancellationToken)
public ValueTask<NestedWriteScope> BeginNestedWriteAsync(Size bufferRequirement, int byteCount, object? state, CancellationToken cancellationToken = default)
Parameters
bufferRequirementSizebyteCountintstateobjectcancellationTokenCancellationToken
Returns
Flush(TimeSpan)
public void Flush(TimeSpan timeout = default)
Parameters
timeoutTimeSpan
FlushAsync(CancellationToken)
public ValueTask FlushAsync(CancellationToken cancellationToken = default)
Parameters
cancellationTokenCancellationToken
Returns
GetStream(bool)
Gets a Stream that can be used to write to the underlying buffer.
public Stream GetStream(bool allowMixedIO = false)
Parameters
allowMixedIOboolBlocking flushes during writes that were expected to be non-blocking and vice versa cause an exception to be thrown unless allowMixedIO is set to true, false by default.
Returns
- Stream
The stream.
ShouldFlush(Size)
public bool ShouldFlush(Size bufferRequirement)
Parameters
bufferRequirementSize
Returns
ShouldFlush(int)
public bool ShouldFlush(int byteCount)
Parameters
byteCountint
Returns
WriteAsOid(PgTypeId)
public void WriteAsOid(PgTypeId pgTypeId)
Parameters
pgTypeIdPgTypeId
WriteByte(byte)
public void WriteByte(byte value)
Parameters
valuebyte
WriteBytes(ReadOnlySpan<byte>)
public void WriteBytes(ReadOnlySpan<byte> buffer)
Parameters
bufferReadOnlySpan<byte>
WriteBytesAsync(ReadOnlyMemory<byte>, CancellationToken)
public ValueTask WriteBytesAsync(ReadOnlyMemory<byte> buffer, CancellationToken cancellationToken = default)
Parameters
bufferReadOnlyMemory<byte>cancellationTokenCancellationToken
Returns
WriteChars(ReadOnlySpan<char>, Encoding)
public void WriteChars(ReadOnlySpan<char> data, Encoding encoding)
Parameters
dataReadOnlySpan<char>encodingEncoding
WriteCharsAsync(ReadOnlyMemory<char>, Encoding, CancellationToken)
public ValueTask WriteCharsAsync(ReadOnlyMemory<char> data, Encoding encoding, CancellationToken cancellationToken = default)
Parameters
dataReadOnlyMemory<char>encodingEncodingcancellationTokenCancellationToken
Returns
WriteDouble(double)
public void WriteDouble(double value)
Parameters
valuedouble
WriteFloat(float)
public void WriteFloat(float value)
Parameters
valuefloat
WriteInt16(short)
public void WriteInt16(short value)
Parameters
valueshort
WriteInt32(int)
public void WriteInt32(int value)
Parameters
valueint
WriteInt64(long)
public void WriteInt64(long value)
Parameters
valuelong
WriteUInt16(ushort)
public void WriteUInt16(ushort value)
Parameters
valueushort
WriteUInt32(uint)
public void WriteUInt32(uint value)
Parameters
valueuint
WriteUInt64(ulong)
public void WriteUInt64(ulong value)
Parameters
valueulong