Lean  $LEAN_TAG$
QuantConnect.ToolBox.PipeDataProcessor Class Reference

Provides an implementation of IDataProcessor that simply forwards all received data to other attached processors More...

Inheritance diagram for QuantConnect.ToolBox.PipeDataProcessor:
[legend]

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

Detailed Description

Provides an implementation of IDataProcessor that simply forwards all received data to other attached processors

Definition at line 26 of file PipeDataProcessor.cs.

Constructor & Destructor Documentation

◆ PipeDataProcessor() [1/2]

QuantConnect.ToolBox.PipeDataProcessor.PipeDataProcessor ( IEnumerable< IDataProcessor processors)

Initializes a new instance of the PipeDataProcessor class

Parameters
processorsThe processors to pipe the data to

Definition at line 34 of file PipeDataProcessor.cs.

◆ PipeDataProcessor() [2/2]

QuantConnect.ToolBox.PipeDataProcessor.PipeDataProcessor ( params IDataProcessor[]  processors)

Initializes a new instance of the PipeDataProcessor class

Parameters
processorsThe processors to pipe the data to

Definition at line 43 of file PipeDataProcessor.cs.

Member Function Documentation

◆ PipeTo()

void QuantConnect.ToolBox.PipeDataProcessor.PipeTo ( IDataProcessor  processor)

Adds the specified processor to the output pipe

Parameters
processorProcessor to receive data from this pipe

Definition at line 52 of file PipeDataProcessor.cs.

◆ Process()

void QuantConnect.ToolBox.PipeDataProcessor.Process ( IBaseData  data)

Invoked for each piece of data from the source file

Parameters
dataThe data to be processed

Implements QuantConnect.ToolBox.IDataProcessor.

Definition at line 61 of file PipeDataProcessor.cs.

◆ Dispose()

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.


The documentation for this class was generated from the following file: