public abstract class Stage extends Object
Modifier and Type | Field and Description |
---|---|
boolean |
stillOpen |
Constructor and Description |
---|
Stage() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Stage |
connectFrom(Stage s)
connect this stage to its supplier; return this for chaining.
|
abstract Pipe |
deliver(Pipe sink)
execute the pipeline and pump the results into _sink_; this is asynchronous.
|
static Stage |
initial(int count)
construct a new initial stage for the pipeline
|
boolean |
isClosed() |
Licenced under the Apache License, Version 2.0