Lean
$LEAN_TAG$
|
Provides an implementation of IDataProcessor that simply forwards all received data to other attached processors More...
Public Member Functions | |
PipeDataProcessor (IEnumerable< IDataProcessor > processors) | |
Initializes a new instance of the PipeDataProcessor class More... | |
PipeDataProcessor (params IDataProcessor[] processors) | |
Initializes a new instance of the PipeDataProcessor class More... | |
void | PipeTo (IDataProcessor processor) |
Adds the specified processor to the output pipe More... | |
void | Process (IBaseData data) |
Invoked for each piece of data from the source file More... | |
void | Dispose () |
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources. More... | |
Provides an implementation of IDataProcessor that simply forwards all received data to other attached processors
Definition at line 26 of file PipeDataProcessor.cs.
QuantConnect.ToolBox.PipeDataProcessor.PipeDataProcessor | ( | IEnumerable< IDataProcessor > | processors | ) |
Initializes a new instance of the PipeDataProcessor class
processors | The processors to pipe the data to |
Definition at line 34 of file PipeDataProcessor.cs.
QuantConnect.ToolBox.PipeDataProcessor.PipeDataProcessor | ( | params IDataProcessor[] | processors | ) |
Initializes a new instance of the PipeDataProcessor class
processors | The processors to pipe the data to |
Definition at line 43 of file PipeDataProcessor.cs.
void QuantConnect.ToolBox.PipeDataProcessor.PipeTo | ( | IDataProcessor | processor | ) |
Adds the specified processor to the output pipe
processor | Processor to receive data from this pipe |
Definition at line 52 of file PipeDataProcessor.cs.
void QuantConnect.ToolBox.PipeDataProcessor.Process | ( | IBaseData | data | ) |
Invoked for each piece of data from the source file
data | The data to be processed |
Implements QuantConnect.ToolBox.IDataProcessor.
Definition at line 61 of file PipeDataProcessor.cs.
void QuantConnect.ToolBox.PipeDataProcessor.Dispose | ( | ) |
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
Definition at line 72 of file PipeDataProcessor.cs.