public abstract class EveryStage<Incoming> extends OperatorStage<Incoming>
argumentsBuilder, argumentsEntry, argumentsSelector, incomingEntry, operationCall, outgoingBuilder, outgoingEntry, outgoingSelector, outputCollector, remainderFields, RETAIN_COLLECTOR
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Constructor and Description |
---|
EveryStage(FlowProcess flowProcess,
Every every) |
Modifier and Type | Method and Description |
---|---|
Operator |
getOperator() |
cleanup, complete, createArgumentsBuilder, createOutgoingBuilder, getIncomingArgumentsFields, getIncomingPassThroughFields, getOperationDeclaredFields, getOutgoingSelector, initialize, prepare
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
bind, getNext, getNextFor, receiveFirst, start
public EveryStage(FlowProcess flowProcess, Every every)
public Operator getOperator()
getOperator
in class OperatorStage<Incoming>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.