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.