AsyncMessageChannel

AsyncMessageChannel

public AsyncMessageChannel(IMessageAdapter adapter)

asyncMessageChannel = AsyncMessageChannel(adapter)

Canal de mensaje Async que procesa mensajes a través de NewOutMessageAsync.

adapter

IMessageAdapter.

State

public ChannelStates State { get; private set; }

value = asyncMessageChannel.State
asyncMessageChannel.State = value

Consigue el almacenamiento estatal subyacente.

Clear

public void Clear()

asyncMessageChannel.Clear()

Limpia todos los estados de adaptador y reinicia el estado actual para desconectar.

Clone

public IMessageChannel Clone()

result = asyncMessageChannel.Clone()

Crea una copia profunda de un DataSeries

Close

public void Close()

asyncMessageChannel.Close()

Precio de cierre.

DisposeManaged

protected override void DisposeManaged()

asyncMessageChannel.DisposeManaged()

Libera recursos.

Open

public void Open()

asyncMessageChannel.Open()

Precio de apertura.

Resume

public void Resume()

asyncMessageChannel.Resume()

Resucito.

SendInMessageAsync

public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)

result = asyncMessageChannel.SendInMessageAsync(message, cancellationToken)

Procesa un mensaje genérico asincrónicamente.

message

El mensaje para procesar.

cancellationToken

CancellationToken

Suspend

public void Suspend()

asyncMessageChannel.Suspend()

Suspend.

NewOutMessageAsync

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

asyncMessageChannel.NewOutMessageAsync += handler

Nuevo evento de mensaje.

StateChanged

public event Action StateChanged

asyncMessageChannel.StateChanged += handler

Acto de cambio de Estado.