OrchestratorConfigAsyncIntakeSupplier Property

An asynchronous function that supplies a task with (a promise of) a tuple containing an ExternalLine object (an input line to be fed into Data Conveyer) and the source number (1-based) (Func<IGlobalCache, Task<Tuple<string,int>>>). Data Conveyer calls this function when AsyncIntake is true (providing a single parameter - IGlobalCache) in succession until null is received. When end of data is reached (i.e. intake sources are depleted), the function must return a task with null result (end of data mark), which will initiate processing shutdown with a status of IntakeDepleted. Note the difference between null tuples (end of data marks) and tuples containing null strings (ignored by Data Conveyer). Any returned tuples that contain null ExternalLine objects are ignored by Data Conveyer; to send an empty line, a tuple containing an empty object (e.g. an empty string) needs to be returned. If not defined, Data Conveyer assumes default AsyncIntakeSupplier function that returns no data, but a task with an end of data result, i.e.: Any exception thrown by this function will cause the process shutdown with a completion status of Failed.

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

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