public class ParallelFork<Outgoing> extends Fork<TupleEntry,Outgoing>
Constructor and Description |
---|
ParallelFork(Duct[] allNext) |
Modifier and Type | Method and Description |
---|---|
void |
complete(Duct previous) |
void |
initialize() |
void |
receive(Duct previous,
TupleEntry incoming) |
void |
start(Duct previous) |
bind, cleanup, getNextFor, prepare, receiveFirst, toString
public ParallelFork(Duct[] allNext)
public void initialize()
initialize
in class Duct<TupleEntry,Outgoing>
public void receive(Duct previous, TupleEntry incoming)
receive
in class Fork<TupleEntry,Outgoing>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.