CandleBuilderMessageAdapter

CandleBuilderMessageAdapter

public CandleBuilderMessageAdapter(IMessageAdapter innerAdapter, CandleBuilderProvider candleBuilderProvider, bool cloneOutCandles)

candleBuilderMessageAdapter = CandleBuilderMessageAdapter(innerAdapter, candleBuilderProvider, cloneOutCandles)

Inicializa uma nova instância do CandleBuilderMessageAdapter.

innerAdapter

Adaptador de mensagens interior.

candleBuilderProvider

Fornecedor de velas.

cloneOutCandles

Indica se velas de saída devem ser clonadas antes de emitir.

CandleBuilderMessageAdapter

public CandleBuilderMessageAdapter(IMessageAdapter innerAdapter, CandleBuilderProvider candleBuilderProvider, ICandleBuilderManager manager, bool cloneOutCandles)

candleBuilderMessageAdapter = CandleBuilderMessageAdapter(innerAdapter, candleBuilderProvider, manager, cloneOutCandles)

Inicializa uma nova instância do CandleBuilderMessageAdapter com um gerenciador personalizado.

innerAdapter

Adaptador de mensagens interior.

candleBuilderProvider

Fornecedor de velas.

manager

Gerente de construção de velas.

cloneOutCandles

Indica se velas de saída devem ser clonadas antes de emitir.

Buffer

public IStorageBuffer Buffer { get; set; }

value = candleBuilderMessageAdapter.Buffer
candleBuilderMessageAdapter.Buffer = value

Tampão de armazenamento.

SendFinishedCandlesImmediatelly

public bool SendFinishedCandlesImmediatelly { get; set; }

value = candleBuilderMessageAdapter.SendFinishedCandlesImmediatelly
candleBuilderMessageAdapter.SendFinishedCandlesImmediatelly = value

Envie velas acabadas quando receberem.

Clone

public override IMessageAdapter Clone()

result = candleBuilderMessageAdapter.Clone()

Criar uma cópia de CandleBuilderMessageAdapter.

Retorna: Entendido.

OnInnerAdapterNewOutMessageAsync

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = candleBuilderMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Processo InnerAdapter output message.

message

A mensagem.

cancellationToken

Inscrição de cancelamento.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = candleBuilderMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Enviar mensagem.

message

Message.

cancellationToken

CancellationToken