Class MuxedStream

A Stream which reads/writes from a specific channel using a StreamDemuxer.

Inheritance

object

MarshalByRefObject

Stream

MuxedStream

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

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

Stream.ReadTimeout

Stream.WriteTimeout

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

Namespace: k8s

Assembly: KubernetesClient.dll

Syntax

public class MuxedStream : Stream, IDisposable, IAsyncDisposable

Constructors

MuxedStream(StreamDemuxer, ByteBuffer, byte?)

Initializes a new instance of the MuxedStream class.

Declaration

public MuxedStream(StreamDemuxer muxer, ByteBuffer inputBuffer, byte? outputIndex)

Parameters

Type	Name	Description
StreamDemuxer	muxer	The StreamDemuxer to use to read from/write to the underlying stream.
ByteBuffer	inputBuffer	The k8s.MuxedStream.inputBuffer to read from.
byte?	outputIndex	The index of the channel to which to write.

Properties

CanRead

Declaration

public override bool CanRead { get; }

Property Value

Type	Description
bool

Overrides

Stream.CanRead

CanSeek

Declaration

public override bool CanSeek { get; }

Property Value

Type	Description
bool

Overrides

Stream.CanSeek

CanWrite

Declaration

public override bool CanWrite { get; }

Property Value

Type	Description
bool

Overrides

Stream.CanWrite

Length

Declaration

public override long Length { get; }

Property Value

Type	Description
long

Overrides

Stream.Length

Position

Declaration

public override long Position { get; set; }

Property Value

Type	Description
long

Overrides

Stream.Position

Methods

Flush()

Declaration

public override void Flush()

Overrides

Stream.Flush()

Read(byte[], int, int)

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)

Seek(long, SeekOrigin)

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)

Declaration

public override void SetLength(long value)

Parameters

Type	Name	Description
long	value

Overrides

Stream.SetLength(long)

Write(byte[], int, int)

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