|
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.