public class CloseReducingDuct<Group,Incoming,Outgoing> extends Duct<Incoming,Outgoing> implements CloseWindow, Reducing<Group,Outgoing>
Constructor and Description |
---|
CloseReducingDuct(Duct<Outgoing,?> next) |
Modifier and Type | Method and Description |
---|---|
void |
completeGroup(Duct previous,
Outgoing outgoing) |
void |
receive(Duct previous,
Incoming incoming) |
void |
startGroup(Duct previous,
Group group) |
bind, cleanup, complete, getNext, getNextFor, initialize, prepare, receiveFirst, start, toString
public CloseReducingDuct(Duct<Outgoing,?> next)
public void startGroup(Duct previous, Group group)
startGroup
in interface Reducing<Group,Outgoing>
public void completeGroup(Duct previous, Outgoing outgoing)
completeGroup
in interface Reducing<Group,Outgoing>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.