Title here
Summary here
A destination in memory - it will store all data in a BlockingCollection<T> The BlockingCollection<T> allows you to access the data concurrently while rows are still written into the target. If you don't need to work with your data before the flow finishes, you can use the MemoryDestination which uses a regular List<T>.
public class ConcurrentMemoryDestination<TInput> : MemoryDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Name | Description |
---|---|
TInput | Type of ingoing data. |
public ConcurrentMemoryDestination()
public bool ClearDataOnStart { get; }
Type | Description |
---|---|
bool |
public BlockingCollection<TInput> Data { get; set; }
Type | Description |
---|---|
BlockingCollection<TInput> |
protected override void AddData(TInput row)
Type | Name | Description |
---|---|---|
TInput | row |
protected override void CleanUpOnFaulted(Exception e)
Type | Name | Description |
---|---|---|
Exception | e |
protected override void CleanUpOnSuccess()
protected override void Reset()