Class ArrayPoolMemoryStream

Namespace

CryptoHives.Foundation.Memory.Buffers

Assembly

CryptoHives.Foundation.Memory.dll

Class to create a MemoryStream which uses ArrayPool buffers.

public sealed class ArrayPoolMemoryStream : MemoryStream, IDisposable

Inheritance

object

MarshalByRefObject

Stream

MemoryStream

ArrayPoolMemoryStream

Implements

IDisposable

Inherited Members

MemoryStream.FlushAsync(CancellationToken)

MemoryStream.GetBuffer()

MemoryStream.TryGetBuffer(out ArraySegment<byte>)

MemoryStream.ReadAsync(byte[], int, int, CancellationToken)

MemoryStream.CopyToAsync(Stream, int, CancellationToken)

MemoryStream.WriteAsync(byte[], int, int, CancellationToken)

MemoryStream.WriteTo(Stream)

MemoryStream.Capacity

Stream.Null

Stream.CopyToAsync(Stream)

Stream.CopyToAsync(Stream, int)

Stream.CopyTo(Stream)

Stream.CopyTo(Stream, int)

Stream.Close()

Stream.Dispose()

Stream.FlushAsync()

Stream.BeginRead(byte[], int, int, AsyncCallback, object)

Stream.EndRead(IAsyncResult)

Stream.ReadAsync(byte[], int, int)

Stream.BeginWrite(byte[], int, int, AsyncCallback, object)

Stream.EndWrite(IAsyncResult)

Stream.WriteAsync(byte[], int, int)

Stream.Synchronized(Stream)

Stream.CanTimeout

Stream.ReadTimeout

Stream.WriteTimeout

MarshalByRefObject.GetLifetimeService()

MarshalByRefObject.InitializeLifetimeService()

MarshalByRefObject.CreateObjRef(Type)

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

Constructors

ArrayPoolMemoryStream()

Initializes a new instance of the ArrayPoolMemoryStream class. Creates a writeable stream that creates buffers as necessary using buffer defaults.

public ArrayPoolMemoryStream()

ArrayPoolMemoryStream(IEnumerable<ArraySegment<byte>>)

Initializes a new instance of the ArrayPoolMemoryStream class. Attaches the stream to read from a enumerable of buffers wrapped in ArraySegment<T>. Buffers are not returned to the ArrayPool when the stream is disposed.

public ArrayPoolMemoryStream(IEnumerable<ArraySegment<byte>> buffers)

Parameters

buffers IEnumerable<ArraySegment<byte>>

ArrayPoolMemoryStream(int)

Initializes a new instance of the ArrayPoolMemoryStream class. Creates a writeable stream that creates buffers as necessary using buffer list size defaults.

public ArrayPoolMemoryStream(int bufferSize)

Parameters

bufferSize int

ArrayPoolMemoryStream(int, int)

Initializes a new instance of the ArrayPoolMemoryStream class. Creates a writeable stream that creates buffers as necessary.

public ArrayPoolMemoryStream(int bufferListSize, int bufferSize)

Parameters

bufferListSize int

bufferSize int

ArrayPoolMemoryStream(int, int, int, int)

Initializes a new instance of the ArrayPoolMemoryStream class. Creates a writeable stream that rents ArrayPool buffers as necessary.

public ArrayPoolMemoryStream(int bufferListSize, int bufferSize, int start, int count)

Parameters

bufferListSize int

The initial size of the buffer list

bufferSize int

The size of the buffers

start int

The start of the ArraySegment in a buffer

count int

The count of bytes in the ArraySegment that is used in the buffer

Exceptions

ArgumentException

Fields

DefaultBufferListSize

The default list size for the array segments.

public static readonly int DefaultBufferListSize

Field Value

int

DefaultBufferSize

The default buffer size of the allocated array pool buffers.

public static readonly int DefaultBufferSize

Field Value

int

Properties

CanRead

Gets a value indicating whether the current stream supports reading.

public override bool CanRead { get; }

Property Value

bool

true if the stream is open.

CanSeek

Gets a value indicating whether the current stream supports seeking.

public override bool CanSeek { get; }

Property Value

bool

true if the stream is open.

CanWrite

Gets a value indicating whether the current stream supports writing.

public override bool CanWrite { get; }

Property Value

bool

true if the stream supports writing; otherwise, false.

Length

Gets the length of the stream in bytes.

public override long Length { get; }

Property Value

long

The length of the stream in bytes.

Exceptions

ObjectDisposedException

The stream is closed.

Position

Gets or sets the current position within the stream.

public override long Position { get; set; }

Property Value

long

The current position within the stream.

Exceptions

ArgumentOutOfRangeException

The position is set to a negative value or a value greater than MaxValue.

ObjectDisposedException

The stream is closed.

Methods

Dispose(bool)

Releases the unmanaged resources used by the MemoryStream class and optionally releases the managed resources.

protected override void Dispose(bool disposing)

Parameters

disposing bool

true to release both managed and unmanaged resources; false to release only unmanaged resources.

Flush()

Overrides the Flush() method so that no action is performed.

public override void Flush()

GetReadOnlySequence()

Returns a ReadOnlySequence<T> of the buffers stored in the stream. ReadOnlySequence is only valid as long as the stream is not disposed and no more data is written.

public ReadOnlySequence<byte> GetReadOnlySequence()

Returns

ReadOnlySequence<byte>

Read(byte[], int, int)

Reads a block of bytes from the current stream and writes the data to a buffer.

public override int Read(byte[] buffer, int offset, int count)

Parameters

buffer byte[]

When this method returns, contains the specified byte array with the values between offset and (offset + count - 1) replaced by the characters read from the current stream.

offset int

The zero-based byte offset in buffer at which to begin storing data from the current stream.

count int

The maximum number of bytes to read.

Returns

int

The total number of bytes written into the buffer. This can be less than the number of bytes requested if that number of bytes are not currently available, or zero if the end of the stream is reached before any bytes are read.

Exceptions

ArgumentNullException

buffer is null.

ArgumentOutOfRangeException

offset or count is negative.

ArgumentException

offset subtracted from the buffer length is less than count.

ObjectDisposedException

The current stream instance is closed.

Read(Span<byte>)

public int Read(Span<byte> destination)

Parameters

destination Span<byte>

Returns

int

ReadByte()

Reads a byte from the current stream.

public override int ReadByte()

Returns

int

The byte cast to a int, or -1 if the end of the stream has been reached.

Exceptions

ObjectDisposedException

The current stream instance is closed.

ReadExactly(byte[], int, int)

Reads count bytes from the current stream and advances the position within the stream.

public void ReadExactly(byte[] buffer, int offset, int count)

Parameters

buffer byte[]

An array of bytes. When this method returns, the buffer contains the specified byte array with the values between offset and (offset + count - 1) replaced by the bytes read from the current source.

offset int

The byte offset in buffer at which to begin storing the data read from the current stream.

count int

The number of bytes to be read from the current stream.

Exceptions

EndOfStreamException

The end of the stream is reached before reading count bytes.

ReadExactly(Span<byte>)

Reads bytes from the current stream and advances the position within the stream until the buffer is filled.

public void ReadExactly(Span<byte> buffer)

Parameters

buffer Span<byte>

A region of memory. When this method returns, the contents of this region are replaced by the bytes read from the current stream.

Exceptions

EndOfStreamException

The end of the stream is reached before filling the buffer.

Seek(long, SeekOrigin)

Sets the position within the current stream to the specified value.

public override long Seek(long offset, SeekOrigin loc)

Parameters

offset long

The new position within the stream. This is relative to the loc parameter, and can be positive or negative.

loc SeekOrigin

A value of type SeekOrigin, which acts as the seek reference point.

Returns

long

The new position within the stream, calculated by combining the initial reference point and the offset.

Exceptions

IOException

Seeking is attempted before the beginning of the stream.

ArgumentOutOfRangeException

offset is greater than MaxValue.

ArgumentException

There is an invalid SeekOrigin. -or-offset caused an arithmetic overflow.

ObjectDisposedException

The current stream instance is closed.

SetLength(long)

Sets the length of the current stream to the specified value.

public override void SetLength(long value)

Parameters

value long

The value at which to set the length.

Exceptions

NotSupportedException

The current stream is not resizable and value is larger than the current capacity.-or- The current stream does not support writing.

ArgumentOutOfRangeException

value is negative or is greater than the maximum length of the MemoryStream, where the maximum length is(MaxValue - origin), and origin is the index into the underlying buffer at which the stream starts.

ToArray()

Writes the stream contents to a byte array, regardless of the Position property.

public override byte[] ToArray()

Returns

byte[]

A new byte array.

TryCopyTo(Span<byte>, out int)

Attempts to copy the stream content into the provided destination span. Returns true on success, false if the destination is too small.

public bool TryCopyTo(Span<byte> destination, out int bytesWritten)

Parameters

destination Span<byte>

The destination span that receives the stream content.

bytesWritten int

When this method returns, contains the number of bytes written to destination.

Returns

bool

true if the content was copied; otherwise false.

Write(byte[], int, int)

Writes a block of bytes to the current stream using data read from a buffer.

public override void Write(byte[] buffer, int offset, int count)

Parameters

buffer byte[]

The buffer to write data from.

offset int

The zero-based byte offset in buffer at which to begin copying bytes to the current stream.

count int

The maximum number of bytes to write.

Exceptions

ArgumentNullException

buffer is null.

NotSupportedException

The stream does not support writing. For additional information see CanWrite.-or- The current position is closer than count bytes to the end of the stream, and the capacity cannot be modified.

ArgumentException

offset subtracted from the buffer length is less than count.

ArgumentOutOfRangeException

offset or count are negative.

IOException

An I/O error occurs.

ObjectDisposedException

The current stream instance is closed.

Write(ReadOnlySpan<byte>)

public void Write(ReadOnlySpan<byte> destination)

Parameters

destination ReadOnlySpan<byte>

WriteByte(byte)

Writes a byte to the current stream at the current position.

public override void WriteByte(byte value)

Parameters

value byte

The byte to write.

Exceptions

NotSupportedException

The stream does not support writing. For additional information see CanWrite.-or- The current position is at the end of the stream, and the capacity cannot be modified.

ObjectDisposedException

The current stream is closed.