public abstract class Duct<Incoming,Outgoing> extends Object
Modifier and Type | Field and Description |
---|---|
protected Duct<Outgoing,?> |
next |
protected Integer |
ordinal |
Modifier and Type | Method and Description |
---|---|
void |
bind(StreamGraph streamGraph) |
void |
cleanup() |
void |
complete(Duct previous) |
Duct |
getNext() |
protected Duct |
getNextFor(StreamGraph streamGraph) |
void |
initialize()
Called immediately after bind
|
void |
prepare() |
abstract void |
receive(Duct previous,
Incoming incoming) |
void |
receiveFirst(Incoming incoming) |
void |
start(Duct previous) |
String |
toString() |
public void bind(StreamGraph streamGraph)
protected Duct getNextFor(StreamGraph streamGraph)
public void initialize()
public void prepare()
public final void receiveFirst(Incoming incoming)
public void cleanup()
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.