Module swim.streamlet

Package swim.streamlet

Class AbstractOutlet<O>

java.lang.Object

swim.streamlet.AbstractOutlet<O>

All Implemented Interfaces:

Outlet<O>

Direct Known Subclasses:

AndOutlet, BinaryOutlet, ConditionalOutlet, GetOutlet, InvokeOutlet, KeyOutlet, OrOutlet, StreamletOutlet, UnaryOutlet, ValueInput

public abstract class AbstractOutlet<O>
extends Object
implements Outlet<O>

Field Summary

Fields

Modifier and Type	Field	Description
protected Inlet<? super O>[]	outputs
protected int	version

Constructor Summary

Constructors

Constructor	Description
AbstractOutlet()

Method Summary

Modifier and Type	Method	Description
void	bindOutput(Inlet<? super O> output)	Adds an output to the set of Inlets that depend on the state of this Outlet.
protected void	didInvalidateInput()
protected void	didReconcileInput(int version)
void	disconnectInputs()	Disconnects all Inlets dominated by this Outlet in the dataflow dependency graph.
void	disconnectOutputs()	Disconnects all Outlets dominated by this Outlet in the dataflow graph.
abstract O	get()	Returns the current state of this Outlet.
void	invalidateInput()	Marks this Outlet—and all outputs that depend on the state of this Outlet—as having stale state.
protected void	onInvalidateInput()
protected void	onReconcileInput(int version)
Iterator<Inlet<? super O>>	outputIterator()	Returns an Iterator over the set of Inlets that depend on the state of this Outlet.
void	reconcileInput(int version)	Reconciles the state of this Outlet, if the version of this Outlet's state differs from the target version.
void	unbindOutput(Inlet<? super O> output)	Removes an output from the set of Inlets that depend on the state of this Outlet.
void	unbindOutputs()	Disconnects all outputs from this Outlet by invoking Inlet.unbindInput() on each Inelt that depends on the state of this Outlet.
protected void	willInvalidateInput()
protected void	willReconcileInput(int version)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface swim.streamlet.Outlet

map, memoize, watch

Field Detail

outputs

protected Inlet<? super O>[] outputs

version

protected int version

Constructor Detail

AbstractOutlet

public AbstractOutlet()

Method Detail

get

public abstract O get()

Description copied from interface: Outlet

Returns the current state of this Outlet.

Specified by:

get in interface Outlet<O>

outputIterator

public Iterator<Inlet<? super O>> outputIterator()

Description copied from interface: Outlet

Returns an Iterator over the set of Inlets that depend on the state of this Outlet.

Specified by:

outputIterator in interface Outlet<O>

bindOutput

public void bindOutput(Inlet<? super O> output)

Description copied from interface: Outlet

Adds an output to the set of Inlets that depend on the state of this Outlet. The output will be invalidated when the state of this Outlet is invalidated, and updated when this Outlet is updated.

Specified by:

bindOutput in interface Outlet<O>

unbindOutput

public void unbindOutput(Inlet<? super O> output)

Description copied from interface: Outlet

Removes an output from the set of Inlets that depend on the state of this Outlet.

Specified by:

unbindOutput in interface Outlet<O>

unbindOutputs

public void unbindOutputs()

Description copied from interface: Outlet

Disconnects all outputs from this Outlet by invoking Inlet.unbindInput() on each Inelt that depends on the state of this Outlet.

Specified by:

unbindOutputs in interface Outlet<O>

disconnectOutputs

public void disconnectOutputs()

Description copied from interface: Outlet

Disconnects all Outlets dominated by this Outlet in the dataflow graph. Used to recursively clean up chains of combinators originating from this Inlet.

Specified by:

disconnectOutputs in interface Outlet<O>

disconnectInputs

public void disconnectInputs()

Description copied from interface: Outlet

Disconnects all Inlets dominated by this Outlet in the dataflow dependency graph. Used to recursively clean up chains of combinators passing through this Outlet.

Specified by:

disconnectInputs in interface Outlet<O>

invalidateInput

public void invalidateInput()

Description copied from interface: Outlet

Marks this Outlet—and all outputs that depend on the state of this Outlet—as having stale state.

Specified by:

invalidateInput in interface Outlet<O>

reconcileInput

public void reconcileInput(int version)

Description copied from interface: Outlet

Reconciles the state of this Outlet, if the version of this Outlet's state differs from the target version. To reconcile its state, the Outlet first invokes Streamlet.reconcile(int) on the Streamlet to which it's attached. It then invokes Inlet.reconcileOutput(int) on each of its dependent outputs.

Specified by:

reconcileInput in interface Outlet<O>

willInvalidateInput

protected void willInvalidateInput()

onInvalidateInput

protected void onInvalidateInput()

didInvalidateInput

protected void didInvalidateInput()

willReconcileInput

protected void willReconcileInput(int version)

onReconcileInput

protected void onReconcileInput(int version)

didReconcileInput

protected void didReconcileInput(int version)