public class OpenDuct<Incoming,Outgoing> extends Duct<Grouping<Incoming,Iterator<Incoming>>,Outgoing> implements OpenWindow
Modifier and Type | Method and Description |
---|---|
void |
complete(Duct previous) |
void |
receive(Duct previous,
Grouping<Incoming,Iterator<Incoming>> grouping) |
void |
start(Duct previous) |
bind, cleanup, getNext, getNextFor, initialize, prepare, receiveFirst, toString
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.