AsyncMessageChannel

StockSharp.Messages

Async Nachrichtenkanal, der Nachrichten über NewOutMessageAsync verarbeitet.

Erbt von: Disposable

Implementiert: IMessageChannel, IMessageTransport, IDisposable, ICloneable<IMessageChannel>, ICloneable

Konstruktoren

AsyncMessageChannel
public AsyncMessageChannel(IMessageAdapter adapter)
asyncMessageChannel = AsyncMessageChannel(adapter)

Async Nachrichtenkanal, der Nachrichten über NewOutMessageAsync verarbeitet.

adapter
IMessageAdapter.

Eigenschaften

State
public ChannelStates State { get; private set; }
value = asyncMessageChannel.State
asyncMessageChannel.State = value

Bekommt den zugrunde liegenden Zustandsspeicher.

Methoden

Clear
public void Clear()
asyncMessageChannel.Clear()

Löscht alle Adapterzustände und setzt den aktuellen Zustand auf Disconnected zurück.

Clone
public IMessageChannel Clone()
result = asyncMessageChannel.Clone()

Erstellt eine tiefe Kopie eines DataSeries

Close
public void Close()
asyncMessageChannel.Close()

Schlusspreis.

DisposeManaged
protected override void DisposeManaged()
asyncMessageChannel.DisposeManaged()

Ressourcen freigeben.

Open
public void Open()
asyncMessageChannel.Open()

Eröffnungspreis.

Resume
public void Resume()
asyncMessageChannel.Resume()

Lebenslauf.

SendInMessageAsync
public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)
result = asyncMessageChannel.SendInMessageAsync(message, cancellationToken)

Verarbeitet eine generische Nachricht asynchron.

message
Die Botschaft zum Prozess.
cancellationToken
CancellationToken
Suspend
public void Suspend()
asyncMessageChannel.Suspend()

Suspendieren.

Ereignisse

NewOutMessageAsync
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
asyncMessageChannel.NewOutMessageAsync += handler

Neues Nachrichtenereignis.

StateChanged
public event Action StateChanged
asyncMessageChannel.StateChanged += handler

Ereignis der Zustandsänderung.