LoopBackMessageAdapter

StockSharp.Algo

Re-injects loopback (IsBack) messages emitted by the inner pipeline back into it as input messages, instead of surfacing them to external consumers.

Inherits: MessageAdapterWrapper

Constructors

LoopBackMessageAdapter
public LoopBackMessageAdapter(IMessageAdapter innerAdapter)
loopBackMessageAdapter = LoopBackMessageAdapter(innerAdapter)

Re-injects loopback (IsBack) messages emitted by the inner pipeline back into it as input messages, instead of surfacing them to external consumers.

Methods

CloneAsync
public override ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)
result = loopBackMessageAdapter.CloneAsync(cancellationToken)

Create a copy of the adapter.

cancellationToken
CancellationToken

Returns: Copy.

InnerAdapterNewOutMessageAsync
protected override ValueTask InnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = loopBackMessageAdapter.InnerAdapterNewOutMessageAsync(message, cancellationToken)

Process InnerAdapter output message.

message
The message.
cancellationToken
Cancellation token.