Class ChunkStream

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Inheritance

object

MarshalByRefObject

Stream

ChunkStream

Implements

IDisposable

IAsyncDisposable

Inherited Members

Stream.Null

Stream.CopyTo(Stream)

Stream.CopyTo(Stream, int)

Stream.CopyToAsync(Stream)

Stream.CopyToAsync(Stream, int)

Stream.CopyToAsync(Stream, CancellationToken)

Stream.CopyToAsync(Stream, int, CancellationToken)

Stream.Dispose()

Stream.FlushAsync()

Stream.FlushAsync(CancellationToken)

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

Stream.EndRead(IAsyncResult)

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

Stream.ReadExactlyAsync(Memory<byte>, CancellationToken)

Stream.ReadExactlyAsync(byte[], int, int, CancellationToken)

Stream.ReadAtLeastAsync(Memory<byte>, int, bool, CancellationToken)

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

Stream.EndWrite(IAsyncResult)

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

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

Stream.WriteAsync(ReadOnlyMemory<byte>, CancellationToken)

Stream.ReadByte()

Stream.ReadExactly(Span<byte>)

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

Stream.ReadAtLeast(Span<byte>, int, bool)

Stream.Write(ReadOnlySpan<byte>)

Stream.WriteByte(byte)

Stream.Synchronized(Stream)

Stream.ReadTimeout

Stream.WriteTimeout

MarshalByRefObject.GetLifetimeService()

MarshalByRefObject.InitializeLifetimeService()

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Messaging.Sequences.Chunking

Assembly: Silverback.Integration.dll

Syntax

public sealed class ChunkStream : Stream, IDisposable, IAsyncDisposable

Constructors

ChunkStream(IMessageStreamEnumerable<IRawInboundEnvelope>)

Initializes a new instance of the ChunkStream class.

Declaration

public ChunkStream(IMessageStreamEnumerable<IRawInboundEnvelope> source)

Parameters

Type	Name	Description
IMessageStreamEnumerable<IRawInboundEnvelope>	source	The chunks composing this stream.

Properties

CanRead

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override bool CanRead { get; }

Property Value

Type	Description
bool

Overrides

Stream.CanRead

CanSeek

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override bool CanSeek { get; }

Property Value

Type	Description
bool

Overrides

Stream.CanSeek

CanTimeout

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override bool CanTimeout { get; }

Property Value

Type	Description
bool

Overrides

Stream.CanTimeout

CanWrite

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override bool CanWrite { get; }

Property Value

Type	Description
bool

Overrides

Stream.CanWrite

Length

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override long Length { get; }

Property Value

Type	Description
long

Overrides

Stream.Length

Position

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override long Position { get; set; }

Property Value

Type	Description
long

Overrides

Stream.Position

Methods

Close()

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override void Close()

Overrides

Stream.Close()

Dispose(bool)

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

protected override void Dispose(bool disposing)

Parameters

Type	Name	Description
bool	disposing

Overrides

Stream.Dispose(bool)

DisposeAsync()

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override ValueTask DisposeAsync()

Returns

Type	Description
ValueTask

Overrides

Stream.DisposeAsync()

Flush()

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override void Flush()

Overrides

Stream.Flush()

Read(byte[], int, int)

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

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

Parameters

Type	Name	Description
byte[]	buffer
int	offset
int	count

Returns

Type	Description
int

Overrides

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

Read(Span<byte>)

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override int Read(Span<byte> buffer)

Parameters

Type	Name	Description
Span<byte>	buffer

Returns

Type	Description
int

Overrides

Stream.Read(Span<byte>)

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

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override Task<int> ReadAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)

Parameters

Type	Name	Description
byte[]	buffer
int	offset
int	count
CancellationToken	cancellationToken

Returns

Type	Description
Task<int>

Overrides

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

ReadAsync(Memory<byte>, CancellationToken)

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

Parameters

Type	Name	Description
Memory<byte>	buffer
CancellationToken	cancellationToken

Returns

Type	Description
ValueTask<int>

Overrides

Stream.ReadAsync(Memory<byte>, CancellationToken)

Seek(long, SeekOrigin)

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override long Seek(long offset, SeekOrigin origin)

Parameters

Type	Name	Description
long	offset
SeekOrigin	origin

Returns

Type	Description
long

Overrides

Stream.Seek(long, SeekOrigin)

SetLength(long)

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

public override void SetLength(long value)

Parameters

Type	Name	Description
long	value

Overrides

Stream.SetLength(long)

Write(byte[], int, int)

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

Declaration

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

Parameters

Type	Name	Description
byte[]	buffer
int	offset
int	count

Overrides

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

Implements

IDisposable

IAsyncDisposable