Class StreamMessage

Represents message which content is represented by Stream.

Inheritance

object

Disposable

StreamTransferObject

StreamMessage

Implements

IDisposableMessage

IMessage

IDataTransferObject

IDisposable

IAsyncDisposable

Inherited Members

StreamTransferObject.LoadFromAsync(IDataTransferObject, CancellationToken)

StreamTransferObject.IsReusable

StreamTransferObject.TransformAsync<TResult, TTransformation>(TTransformation, CancellationToken)

StreamTransferObject.Dispose(bool)

StreamTransferObject.DisposeAsyncCore()

StreamTransferObject.DisposeAsync()

Disposable.IsDisposed

Disposable.IsDisposing

Disposable.IsDisposingOrDisposed

Disposable.DisposedTask

Disposable.GetDisposedTask<T>()

Disposable.TrySetDisposedException<T>(TaskCompletionSource<T>)

Disposable.TrySetDisposedException(TaskCompletionSource)

Disposable.TryBeginDispose()

Disposable.Dispose()

Disposable.Dispose(IEnumerable<IDisposable>)

Disposable.DisposeAsync(IEnumerable<IAsyncDisposable>)

Disposable.Dispose(ReadOnlySpan<IDisposable>)

Disposable.DisposeAsync(params IAsyncDisposable[])

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: DotNext.Net.Cluster.Messaging

Assembly: DotNext.Net.Cluster.dll

Syntax

public class StreamMessage : StreamTransferObject, IDisposableMessage, IMessage, IDataTransferObject, IDisposable, IAsyncDisposable

Constructors

StreamMessage(Stream, bool, string, ContentType?)

Represents message which content is represented by Stream.

Declaration

public StreamMessage(Stream content, bool leaveOpen, string name, ContentType? type = null)

Parameters

Type	Name	Description
Stream	content	The message content.
bool	leaveOpen	true to leave the stream open after StreamMessage object is disposed; otherwise, false.
string	name	The name of the message.
ContentType	type	Media type of the message.

Properties

Name

Gets name of this message.

Declaration

public string Name { get; }

Property Value

Type	Description
string

Type

Gets media type of this message.

Declaration

public ContentType Type { get; }

Property Value

Type	Description
ContentType

Implements

IDisposableMessage

IMessage

IDataTransferObject

IDisposable

IAsyncDisposable

Extension Methods

Messenger.ReadAsTextAsync(IMessage, CancellationToken)

BasicExtensions.As<T>(T)

BasicExtensions.GetUserData<T>(T)

BasicExtensions.IsBetween<T, TLowerBound, TUpperBound>(T, TLowerBound, TUpperBound)

BasicExtensions.IsOneOf<T>(T, ReadOnlySpan<T>)

DataTransferObject.ToByteArrayAsync<TObject>(TObject, MemoryAllocator<byte>?, CancellationToken)

DataTransferObject.ToMemoryAsync<TObject>(TObject, MemoryAllocator<byte>?, CancellationToken)

DataTransferObject.ToStringAsync<TObject>(TObject, Encoding, MemoryAllocator<byte>?, CancellationToken)

DataTransferObject.TransformAsync<TResult, TObject>(TObject, Func<IAsyncBinaryReader, CancellationToken, ValueTask<TResult>>, CancellationToken)

DataTransferObject.WriteToAsync<TObject>(TObject, IBufferWriter<byte>, CancellationToken)

DataTransferObject.WriteToAsync<TObject>(TObject, PipeWriter, long, CancellationToken)

DataTransferObject.WriteToAsync<TObject>(TObject, Stream, int, CancellationToken)

DataTransferObject.WriteToAsync<TObject>(TObject, Stream, Memory<byte>, CancellationToken)

ExpressionBuilder.Const<T>(T)

AsyncLockAcquisition.AcquireLockAsync<T>(T, CancellationToken)

AsyncLockAcquisition.AcquireLockAsync<T>(T, TimeSpan, CancellationToken)

AsyncLockAcquisition.AcquireReadLockAsync<T>(T, CancellationToken)

AsyncLockAcquisition.AcquireReadLockAsync<T>(T, TimeSpan, CancellationToken)

AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, bool, CancellationToken)

AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, bool, TimeSpan, CancellationToken)

AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, CancellationToken)

AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, TimeSpan, CancellationToken)

LockAcquisition.AcquireReadLock<T>(T)

LockAcquisition.AcquireReadLock<T>(T, TimeSpan)

LockAcquisition.AcquireUpgradeableReadLock<T>(T)

LockAcquisition.AcquireUpgradeableReadLock<T>(T, TimeSpan)

LockAcquisition.AcquireWriteLock<T>(T)

LockAcquisition.AcquireWriteLock<T>(T, TimeSpan)