Overview  Namespace  Classifier  Tree  Index  Help 
PREV   NEXT FRAMES  NO FRAMES
SUMMARY: INNER | FIELD | CONSTR | DESTR | METHOD DETAIL: FIELD | CONSTR | DESTR | METHOD

Namespace: OtlParallel

Interface IOmniPipeline

All Known Implementing Classes:
TOmniPipeline
public interface IOmniPipeline

Persistent
False

Property Summary
  public  OtlCollections.IOmniBlockingCollection Input
 
  public  OtlCollections.IOmniBlockingCollection Output
 
  public  IOmniPipelineStage PipelineStage
 
 

Method Summary
  public Sub Cancel()
 
  public function IOmniPipeline From(queue: OtlCollections.IOmniBlockingCollection )
 
  public function OtlCollections.IOmniBlockingCollection GetInput()
 
  public function OtlCollections.IOmniBlockingCollection GetOutput()
 
  public function IOmniPipelineStage GetPipelineStage(idxStage: integer)
 
  public function IOmniPipeline HandleExceptions()
 
  public function IOmniPipeline NoThrottling()
 
  public function IOmniPipeline NumTasks(numTasks: integer)
 
  public function IOmniPipeline OnStop(stopCode: TProc)
 
  public function IOmniPipeline OnStop(stopCode: TOmniTaskStopDelegate )
 
  public function IOmniPipeline Run()
 
  public function IOmniPipeline Stage(pipelineStage: TPipelineSimpleStageDelegate ; taskConfig: IOmniTaskConfig )
 
  public function IOmniPipeline Stage(pipelineStage: TPipelineStageDelegate ; taskConfig: IOmniTaskConfig )
 
  public function IOmniPipeline Stage(pipelineStage: TPipelineStageDelegateEx ; taskConfig: IOmniTaskConfig )
 
  public function IOmniPipeline Stages(pipelineStages: TPipelineSimpleStageDelegate ; taskConfig: IOmniTaskConfig )
 
  public function IOmniPipeline Stages(pipelineStages: TPipelineStageDelegate ; taskConfig: IOmniTaskConfig )
 
  public function IOmniPipeline Stages(pipelineStages: TPipelineStageDelegateEx ; taskConfig: IOmniTaskConfig )
 
  public function IOmniPipeline Throttle(numEntries: integer; unblockAtCount: integer)
 
  public function boolean WaitFor(timeout_ms: cardinal)
 
 

Property Detail

Input

public Input: OtlCollections.IOmniBlockingCollection
Type
IOmniBlockingCollection
Access
read

Output

public Output: OtlCollections.IOmniBlockingCollection
Type
IOmniBlockingCollection
Access
read

PipelineStage

public PipelineStage: IOmniPipelineStage
Type
IOmniPipelineStage
Access
read
Method Detail

Cancel

public procedure Cancel()
Reintroduce
False

From

public function From(queue: OtlCollections.IOmniBlockingCollection ): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

GetInput

public function GetInput(): OtlCollections.IOmniBlockingCollection
Reintroduce
False
Returns
IOmniBlockingCollection

GetOutput

public function GetOutput(): OtlCollections.IOmniBlockingCollection
Reintroduce
False
Returns
IOmniBlockingCollection

GetPipelineStage

public function GetPipelineStage(idxStage: integer): IOmniPipelineStage
Reintroduce
False
Returns
IOmniPipelineStage

HandleExceptions

public function HandleExceptions(): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

NoThrottling

public function NoThrottling(): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

NumTasks

public function NumTasks(numTasks: integer): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

OnStop

public function OnStop(stopCode: TProc): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

OnStop

public function OnStop(stopCode: TOmniTaskStopDelegate ): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

Run

public function Run(): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

Stage

public function Stage(pipelineStage: TPipelineSimpleStageDelegate ; taskConfig: IOmniTaskConfig ): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

Stage

public function Stage(pipelineStage: TPipelineStageDelegate ; taskConfig: IOmniTaskConfig ): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

Stage

public function Stage(pipelineStage: TPipelineStageDelegateEx ; taskConfig: IOmniTaskConfig ): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

Stages

public function Stages(pipelineStages: TPipelineSimpleStageDelegate ; taskConfig: IOmniTaskConfig ): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

Stages

public function Stages(pipelineStages: TPipelineStageDelegate ; taskConfig: IOmniTaskConfig ): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

Stages

public function Stages(pipelineStages: TPipelineStageDelegateEx ; taskConfig: IOmniTaskConfig ): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

Throttle

public function Throttle(numEntries: integer; unblockAtCount: integer): IOmniPipeline
Reintroduce
False
Returns
IOmniPipeline

WaitFor

public function WaitFor(timeout_ms: cardinal): boolean
Reintroduce
False
Returns
boolean

Association Link

to Interface IOmniBlockingCollection

Supplier
IOmniBlockingCollection
Directed
False
Client
Input
Type
association

to Interface IOmniBlockingCollection

Supplier
IOmniBlockingCollection
Directed
False
Client
Output
Type
association

to Interface IOmniPipelineStage

Supplier
IOmniPipelineStage
Directed
False
Client
PipelineStage
Type
association

Overview  Namespace  Classifier  Tree  Index  Help 
PREV   NEXT FRAMES  NO FRAMES
SUMMARY: INNER | FIELD | CONSTR | DESTR | METHOD DETAIL: FIELD | CONSTR | DESTR | METHOD