Uses of Class
teetime.framework.InputPort

Packages that use InputPort

Package	Description
teetime.framework	Contains the implementation of the TeeTime framework.
teetime.framework.pipe	Contains all pipes related classes, such as factories and pre-defined pipes.
teetime.framework.scheduling.globaltaskpool
teetime.framework.signal	Contains the signals that are used within the framework.
teetime.framework.test	Copyright © 2015 Christian Wulf, Nelson Tavares de Sousa (http://teetime-framework.github.io) Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License.
teetime.framework.validation
teetime.stage	Contains a set of pre-defined stages, which are ready-to-go and can be used for analysis configuration.
teetime.stage.basic
teetime.stage.basic.distributor.dynamic
teetime.stage.basic.merger
teetime.stage.basic.merger.dynamic
teetime.stage.basic.merger.strategy
teetime.stage.io
teetime.stage.quicksort
teetime.stage.string
teetime.stage.taskfarm

Uses of InputPort in teetime.framework

Subclasses of InputPort in teetime.framework

Modifier and Type	Class and Description
class	DynamicInputPort<T>

Fields in teetime.framework declared as InputPort

Modifier and Type	Field and Description
protected InputPort<I>	AbstractConsumerStage.inputPort

Methods in teetime.framework that return InputPort

Modifier and Type	Method and Description
protected <T> InputPort<T>	AbstractStage.createInputPort() Creates and adds an InputPort to the stage
protected <T> InputPort<T>	AbstractStage.createInputPort(Class<T> type) Creates and adds an InputPort to the stage
protected <T> InputPort<T>	AbstractConsumerStage.createInputPort(Class<T> type, String name)
protected <T> InputPort<T>	AbstractStage.createInputPort(Class<T> type, String name) Creates and adds an InputPort to the stage
protected <T> InputPort<T>	CompositeStage.createInputPort(InputPort<T> subStageInputPort)
protected <T> InputPort<T>	AbstractStage.createInputPort(String name) Creates and adds an InputPort to the stage
InputPort<I>	AbstractConsumerStage.getInputPort()
InputPort<P>	DivideAndConquerStage.getInputPort()
InputPort<T>	AbstractPipe.getTargetPort()
InputPort<T>	InstantiationPipe.getTargetPort()

Methods in teetime.framework that return types with arguments of type InputPort

Modifier and Type	Method and Description
protected List<InputPort<?>>	AbstractStage.getInputPorts()
List<InputPort<?>>	StageFacade.getInputPorts(AbstractStage stage)
List<InputPort<?>>	StageFacade.getInputPorts(CompositeStage stage)

Methods in teetime.framework with parameters of type InputPort

Modifier and Type	Method and Description
void	MonitoringThread.addPort(InputPort<String> inputPort)
protected <T> void	CompositeStage.connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort) Connects two ports with a pipe with a default capacity of currently 512.
<T> void	RuntimeServiceFacade.connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort) Connects two ports with a pipe with an unlimited capacity.
protected <T> void	CompositeStage.connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity) Connects to ports with a pipe of a certain capacity
<T> void	RuntimeServiceFacade.connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity) Connects to ports with a pipe of a certain capacity
<T> void	Configuration.connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity)
<T> void	Configuration.connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity, IPipeFactory pipeFactory)
<T> void	Configuration.connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, IPipeFactory pipeFactory)
protected <T> InputPort<T>	CompositeStage.createInputPort(InputPort<T> subStageInputPort)
void	InputPortRemovedListener.onInputPortRemoved(AbstractStage stage, InputPort<?> removedInputPort)
void	AbstractStage.onSignal(ISignal signal, InputPort<?> inputPort) May not be invoked outside of IPipe implementations
protected void	AbstractStage.removeDynamicPort(InputPort<?> inputPort)
protected boolean	AbstractStage.signalAlreadyReceived(ISignal signal, InputPort<?> inputPort)

Method parameters in teetime.framework with type arguments of type InputPort

Modifier and Type	Method and Description
protected void	AbstractStage.addInputPortRemovedListener(PortRemovedListener<InputPort<?>> inputPortRemovedListener)
<S extends AbstractStage,O> ConfigurationBuilder.Connection<O>	ConfigurationBuilder.Connection.to(S stage, Function<S,InputPort<I>> inputPort, Function<S,OutputPort<O>> outputPort)

Constructors in teetime.framework with parameters of type InputPort

Constructor and Description
AbstractPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort)
AbstractSynchedPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort) Deprecated.
AbstractUnsynchedPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort) Deprecated.
InstantiationPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity)

Uses of InputPort in teetime.framework.pipe

Methods in teetime.framework.pipe that return InputPort

Modifier and Type	Method and Description
InputPort<T>	IPipe.getTargetPort()
InputPort<Object>	DummyPipe.getTargetPort()

Methods in teetime.framework.pipe with parameters of type InputPort

Modifier and Type	Method and Description
<T> IPipe<T>	IPipeFactory.newPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort)
<T> IPipe<T>	BoundedSynchedPipeFactory.newPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort) Uses a default capacity of .
<T> IPipe<T>	IPipeFactory.newPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity)
<T> IPipe<T>	BoundedSynchedPipeFactory.newPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity)

Constructors in teetime.framework.pipe with parameters of type InputPort

Constructor and Description
AbstractSynchedPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort)
AbstractUnsynchedPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort)
BoundedSynchedPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity)
ReflexivePipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort)
UnboundedSynchedPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort)
UnsynchedPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort)

Uses of InputPort in teetime.framework.scheduling.globaltaskpool

Methods in teetime.framework.scheduling.globaltaskpool with parameters of type InputPort

Modifier and Type	Method and Description
int	ITaskQueueInformation.numElementsToDrainPerExecute(InputPort<?> inputPort)

Uses of InputPort in teetime.framework.signal

Method parameters in teetime.framework.signal with type arguments of type InputPort

Modifier and Type	Method and Description
boolean	StartingSignal.mayBeTriggered(Set<InputPort<?>> receivedInputPorts, List<InputPort<?>> allInputPorts)
boolean	StartingSignal.mayBeTriggered(Set<InputPort<?>> receivedInputPorts, List<InputPort<?>> allInputPorts)
boolean	ISignal.mayBeTriggered(Set<InputPort<?>> receivedInputPorts, List<InputPort<?>> allInputPorts)
boolean	ISignal.mayBeTriggered(Set<InputPort<?>> receivedInputPorts, List<InputPort<?>> allInputPorts)
boolean	ValidatingSignal.mayBeTriggered(Set<InputPort<?>> receivedInputPorts, List<InputPort<?>> allInputPorts)
boolean	ValidatingSignal.mayBeTriggered(Set<InputPort<?>> receivedInputPorts, List<InputPort<?>> allInputPorts)
boolean	TerminatingSignal.mayBeTriggered(Set<InputPort<?>> receivedInputPorts, List<InputPort<?>> allInputPorts)
boolean	TerminatingSignal.mayBeTriggered(Set<InputPort<?>> receivedInputPorts, List<InputPort<?>> allInputPorts)

Uses of InputPort in teetime.framework.test

Methods in teetime.framework.test that return types with arguments of type InputPort

Modifier and Type	Method and Description
List<InputPort<?>>	StageUnderTest.getInputPorts()

Methods in teetime.framework.test with parameters of type InputPort

Modifier and Type	Method and Description
StageTester	InputHolder.to(InputPort<? super I> inputPort)

Uses of InputPort in teetime.framework.validation

Methods in teetime.framework.validation that return InputPort

Modifier and Type	Method and Description
InputPort<?>	InvalidPortConnection.getTargetPort()

Constructors in teetime.framework.validation with parameters of type InputPort

Constructor and Description
InvalidPortConnection(OutputPort<?> sourcePort, InputPort<?> targetPort)

Uses of InputPort in teetime.stage

Methods in teetime.stage that return InputPort

Modifier and Type	Method and Description
InputPort<T>	StatelessCounter.getInputPort()
InputPort<Long>	ElementThroughputMeasuringStage.getTriggerInputPort()
InputPort<Long>	ElementDelayMeasuringStage.getTriggerInputPort()

Uses of InputPort in teetime.stage.basic

Methods in teetime.stage.basic that return InputPort

Modifier and Type	Method and Description
InputPort<I>	ITransformation.getInputPort()
InputPort<T>	Delay.getInputPort()
InputPort<Long>	Delay.getTimestampTriggerInputPort()

Uses of InputPort in teetime.stage.basic.distributor.dynamic

Constructors in teetime.stage.basic.distributor.dynamic with parameters of type InputPort

Constructor and Description
CreatePortAction(InputPort<T> inputPort, int capacity) Deprecated.
CreatePortActionDistributor(InputPort<T> inputPort, int capacity)

Uses of InputPort in teetime.stage.basic.merger

Methods in teetime.stage.basic.merger that return InputPort

Modifier and Type	Method and Description
InputPort<T>	Merger.getNewInputPort()

Methods in teetime.stage.basic.merger that return types with arguments of type InputPort

Modifier and Type	Method and Description
List<InputPort<?>>	Merger.getInputPorts()

Uses of InputPort in teetime.stage.basic.merger.dynamic

Methods in teetime.stage.basic.merger.dynamic with parameters of type InputPort

Modifier and Type	Method and Description
void	DynamicMerger.removeDynamicPort(InputPort<?> inputPort)

Constructors in teetime.stage.basic.merger.dynamic with parameters of type InputPort

Constructor and Description
RemovePortAction(InputPort<T> inputPort)

Uses of InputPort in teetime.stage.basic.merger.strategy

Methods in teetime.stage.basic.merger.strategy with parameters of type InputPort

Modifier and Type	Method and Description
void	BusyWaitingRoundRobinStrategy.onPortRemoved(InputPort<?> removedInputPort) Deprecated.
void	NonBlockingFiniteRoundRobinStrategy.onPortRemoved(InputPort<?> removedInputPort)
void	BlockingBusyWaitingRoundRobinMergerStrategy.onPortRemoved(InputPort<?> removedInputPort)
void	RoundRobinStrategy.onPortRemoved(InputPort<?> removedInputPort) Deprecated.

Uses of InputPort in teetime.stage.io

Methods in teetime.stage.io that return InputPort

Modifier and Type	Method and Description
InputPort<T>	EveryXthPrinter.getInputPort()

Uses of InputPort in teetime.stage.quicksort

Methods in teetime.stage.quicksort that return InputPort

Modifier and Type	Method and Description
InputPort<int[]>	QuicksortStage.getInputPort()

Uses of InputPort in teetime.stage.string

Methods in teetime.stage.string that return InputPort

Modifier and Type	Method and Description
InputPort<String>	WordCounter.getInputPort()

Uses of InputPort in teetime.stage.taskfarm

Methods in teetime.stage.taskfarm that return InputPort

Modifier and Type	Method and Description
InputPort<I>	StaticTaskFarmStage.getInputPort() Returns the input port of the task farm/distributor of the task farm.
InputPort<I>	ITaskFarmDuplicable.getInputPort()
InputPort<I>	TaskFarmStage.getInputPort() Deprecated. Returns the input port of the task farm/distributor of the task farm.