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

## Namespace: OtlParallel
Class TOmniPipeline

    System.TInterfacedObject
      |
      +-- OtlParallel.TOmniPipeline

All Implemented Interfaces:
  IOmniPipeline

public class TOmniPipeline ( System.TInterfacedObject , IOmniPipeline )

Sealed
  False

Abstract
  False

Persistent
  False

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

Constructor Summary
`Create()`

Method Summary
`public Sub` | `Cancel()`
`public Sub` | `Destroy()`
`public function IOmniPipeline` | `From(queue: OtlCollections.IOmniBlockingCollection )`
`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

Class
  False

Access
  read

### Output

    public Output: OtlCollections.IOmniBlockingCollection

Type
  IOmniBlockingCollection

Class
  False

Access
  read

### PipelineStage

    public PipelineStage: IOmniPipelineStage

Type
  IOmniPipelineStage

Class
  False

Access
  read

Constructor Detail

### Create

    public constructor Create()

Final
  False

Reintroduce
  False

Virtual
  False

Override
  False

Abstract
  False

Method Detail

### Cancel

    public procedure Cancel()

Final
  False

Reintroduce
  False

Abstract
  False

Override
  False

Virtual
  False

Class
  False

### Destroy

    public procedure Destroy()

Reintroduce
  False

Virtual
  False

Override
  True

Abstract
  False

Final
  False

### From

    public function From(queue: OtlCollections.IOmniBlockingCollection ): IOmniPipeline

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### HandleExceptions

    public function HandleExceptions(): IOmniPipeline

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### NoThrottling

    public function NoThrottling(): IOmniPipeline

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### NumTasks

    public function NumTasks(numTasks: integer): IOmniPipeline

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### OnStop

    public function OnStop(stopCode: TProc): IOmniPipeline

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### OnStop

    public function OnStop(stopCode: TOmniTaskStopDelegate ): IOmniPipeline

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### Run

    public function Run(): IOmniPipeline

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### Stage

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

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### Stage

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

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### Stage

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

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### Stages

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

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### Stages

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

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### Stages

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

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### Throttle

    public function Throttle(numEntries: integer; unblockAtCount: integer): IOmniPipeline

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  IOmniPipeline

Override
  False

Virtual
  False

Class
  False

### WaitFor

    public function WaitFor(timeout_ms: cardinal): boolean

Final
  False

Reintroduce
  False

Abstract
  False

Returns
  boolean

Override
  False

Virtual
  False

Class
  False

Implementation Link

to Interface IOmniPipeline

Client
  TOmniPipeline

Supplier
  IOmniPipeline

Association Link

to Interface IOmniCancellationToken

Supplier
  IOmniCancellationToken

Directed
  False

Client
  opCancelWith

Type
  association

to Interface IOmniResourceCount

Supplier
  IOmniResourceCount

Directed
  False

Client
  opCountStopped

Type
  association

to Interface IOmniBlockingCollection

Supplier
  IOmniBlockingCollection

Directed
  False

Client
  opInput

Type
  association

to Class TOmniTaskStopDelegate

Supplier
  TOmniTaskStopDelegate

Directed
  False

Client
  opOnStop

Type
  association

to Interface IOmniBlockingCollection

Supplier
  IOmniBlockingCollection

Directed
  False

Client
  opOutput

Type
  association

to Class TOmniTransitionEvent

Supplier
  TOmniTransitionEvent

Directed
  False

Client
  opShutDownComplete

Type
  association

to Interface IOmniPipelineStageEx

Supplier
  IOmniPipelineStageEx

Directed
  False

Client
  PipeStage

Type
  association

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