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