AsyncMessageChannel

AsyncMessageChannel

public AsyncMessageChannel(IMessageAdapter adapter)

asyncMessageChannel = AsyncMessageChannel(adapter)

Canal de mensagem assincronizado que processa mensagens via NewOutMessageAsync.

adapter

IMessageAdapter.

State

public ChannelStates State { get; private set; }

value = asyncMessageChannel.State
asyncMessageChannel.State = value

Obtém o armazenamento do estado subjacente.

Clear

public void Clear()

asyncMessageChannel.Clear()

Limpa todos os estados do adaptador e repõe o estado atual para Desligado.

Clone

public IMessageChannel Clone()

result = asyncMessageChannel.Clone()

Cria uma cópia profunda de DataSeries

Close

public void Close()

asyncMessageChannel.Close()

Preço de fecho.

DisposeManaged

protected override void DisposeManaged()

asyncMessageChannel.DisposeManaged()

Libertar recursos.

Open

public void Open()

asyncMessageChannel.Open()

Preço de abertura.

Resume

public void Resume()

asyncMessageChannel.Resume()

Retoma.

SendInMessageAsync

public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)

result = asyncMessageChannel.SendInMessageAsync(message, cancellationToken)

Processa uma mensagem genérica de forma assíncrona.

message

A mensagem para processar.

cancellationToken

CancellationToken

Suspend

public void Suspend()

asyncMessageChannel.Suspend()

Suspenda.

NewOutMessageAsync

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

asyncMessageChannel.NewOutMessageAsync += handler

Novo evento de mensagem.

StateChanged

public event Action StateChanged

asyncMessageChannel.StateChanged += handler

Evento de mudança de estado.