AsyncMessageChannel

AsyncMessageChannel

public AsyncMessageChannel(IMessageAdapter adapter)

asyncMessageChannel = AsyncMessageChannel(adapter)

通过 NewOutMessageAsync 处理消息的 Async 消息通道 。

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()

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

州变事.