Class ChunkedUploadWrapperStream

Namespace

Amazon.Runtime.Internal.Util

Assembly

AWSSDK.Core.dll

Stream wrapper that double-buffers from a wrapped stream and returns the buffered content as a series of signed 'chunks' for the AWS4 ('Signature V4') protocol.

public class ChunkedUploadWrapperStream : WrapperStream, IDisposable, IAsyncDisposable

Inheritance

object

MarshalByRefObject

Stream

WrapperStream

ChunkedUploadWrapperStream

Implements

IDisposable

IAsyncDisposable

Inherited Members

WrapperStream.GetNonWrapperBaseStream()

WrapperStream.GetSeekableBaseStream()

WrapperStream.GetNonWrapperBaseStream(Stream)

WrapperStream.SearchWrappedStream(Func<Stream, bool>)

WrapperStream.SearchWrappedStream(Stream, Func<Stream, bool>)

WrapperStream.Close()

WrapperStream.Flush()

WrapperStream.Seek(long, SeekOrigin)

WrapperStream.SetLength(long)

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

WrapperStream.BaseStream

WrapperStream.CanRead

WrapperStream.CanWrite

WrapperStream.Position

WrapperStream.ReadTimeout

WrapperStream.WriteTimeout

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.Dispose(bool)

Stream.DisposeAsync()

Stream.FlushAsync()

Stream.FlushAsync(CancellationToken)

Stream.CreateWaitHandle()

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

Stream.EndRead(IAsyncResult)

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

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

Stream.ReadAsync(Memory<byte>, CancellationToken)

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.Read(Span<byte>)

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.ObjectInvariant()

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

Stream.ValidateCopyToArguments(Stream, int)

Stream.CanTimeout

MarshalByRefObject.GetLifetimeService()

MarshalByRefObject.InitializeLifetimeService()

MarshalByRefObject.MemberwiseClone(bool)

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Fields

DefaultChunkSize

public static readonly int DefaultChunkSize

Field Value

int

Properties

CanSeek

Gets a value indicating whether the current stream supports seeking. True if the stream supports seeking; otherwise, false.

public override bool CanSeek { get; }

Property Value

bool

Length

Length override to return the true length of the payload plus the metainfo supplied with each chunk

public override long Length { get; }

Property Value

long

Methods

ComputeChunkedContentLength(long)

Computes the total size of the data payload, including the chunk metadata. Called externally so as to be able to set the correct Content-Length header value.

public static long ComputeChunkedContentLength(long originalLength)

Parameters

originalLength long

Returns

long

Read(byte[], int, int)

Reads some or all of the processed chunk to the consumer, constructing and streaming a new chunk if more input data is available.

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

Parameters

buffer byte[]

offset int

count int

Returns

int