AsyncMessageChannel

AsyncMessageChannel

public AsyncMessageChannel(IMessageAdapter adapter)

asyncMessageChannel = AsyncMessageChannel(adapter)

Async message channel that processes messages via NewOutMessageAsync.

adapter

IMessageAdapter.

State

public ChannelStates State { get; private set; }

value = asyncMessageChannel.State
asyncMessageChannel.State = value

State.

Clear

public void Clear()

asyncMessageChannel.Clear()

Clear.

Clone

public IMessageChannel Clone()

result = asyncMessageChannel.Clone()

Creates a new object that is a deep copy of the current instance.

Returns: A new object that is a deep copy of this instance.

Close

public void Close()

asyncMessageChannel.Close()

Close channel.

DisposeManaged

protected override void DisposeManaged()

asyncMessageChannel.DisposeManaged()

Disposes the managed resources. Override this method to add custom clean up of managed resources.

Open

public void Open()

asyncMessageChannel.Open()

Open channel.

Resume

public void Resume()

asyncMessageChannel.Resume()

Resume.

SendInMessageAsync

public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)

result = asyncMessageChannel.SendInMessageAsync(message, cancellationToken)

Processes a generic message asynchronously.

message

The message to process.

cancellationToken

CancellationToken

Suspend

public void Suspend()

asyncMessageChannel.Suspend()

Suspend.

NewOutMessageAsync

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

asyncMessageChannel.NewOutMessageAsync += handler

New message event.

StateChanged

public event Action StateChanged

asyncMessageChannel.StateChanged += handler

State change event.