AsyncMessageChannel

AsyncMessageChannel

public AsyncMessageChannel(IMessageAdapter adapter)

asyncMessageChannel = AsyncMessageChannel(adapter)

Канал асинхронных сообщений, который обрабатывает сообщения через NewOutMessageAsync.

adapter

IMessageAdapter.

State

public ChannelStates State { get; private set; }

value = asyncMessageChannel.State
asyncMessageChannel.State = value

Получает базовое хранилище.

Clear

public void Clear()

asyncMessageChannel.Clear()

Очищает все состояния адаптера и сбрасывает текущее состояние на «Отключено».

Clone

public IMessageChannel Clone()

result = asyncMessageChannel.Clone()

Создает глубокую копию DataSeries.

Close

public void Close()

asyncMessageChannel.Close()

Цена закрытия.

DisposeManaged

protected override void DisposeManaged()

asyncMessageChannel.DisposeManaged()

Освободите ресурсы.

Open

public void Open()

asyncMessageChannel.Open()

Цена открытия.

Resume

public void Resume()

asyncMessageChannel.Resume()

Резюме.

SendInMessageAsync

public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)

result = asyncMessageChannel.SendInMessageAsync(message, cancellationToken)

Обрабатывает общее сообщение асинхронно.

message

Сообщение для обработки.

cancellationToken

CancellationToken

Suspend

public void Suspend()

asyncMessageChannel.Suspend()

Приостановить.

NewOutMessageAsync

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

asyncMessageChannel.NewOutMessageAsync += handler

Новое событие сообщения.

StateChanged

public event Action StateChanged

asyncMessageChannel.StateChanged += handler

Событие изменения состояния.