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 deep copy of a DataSeries

Close

public void Close()

asyncMessageChannel.Close()

Close channel.

DisposeManaged

protected override void DisposeManaged()

asyncMessageChannel.DisposeManaged()

Release 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.