OrchestratorConfigAsyncOutputConsumer Property

An asynchronous action (Task returning function) that consumes a tuple containing a ExternalLine object (a single output line received from Data Conveyer) and the target number (Func<Tuple<string, int>, Task>). Reference to global cache (IGlobalCache) is passed as the second parameter. The function is intended for use in case of a long-running operation to consume the output line, e.g. await LongRunningOperation(..). Data Conveyer calls this action (when AsyncOutput is true) in succession passing (tuples with) the output lines one at a time. The last tuple sent by Data Conveyer is always null (end of data mark). If not defined, Data Conveyer assumes default AsyncOutputConsumer action that ignores data passed to it, i.e.: Any exception thrown by this action will cause the process shutdown with a CompletionStatus of Failed.

public Func<Tuple<ExternalLine, int>, IGlobalCache, Task> AsyncOutputConsumer { get; set; }

Public Property AsyncOutputConsumer As Func(Of Tuple(Of ExternalLine, Integer), IGlobalCache, Task)
	Get
	Set