- 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>
-
-
Constructor Summary
Constructors Constructor Description AbstractOutlet()
-
Method Summary
Modifier and Type Method Description void
bindOutput(Inlet<? super O> output)
Adds anoutput
to the set ofInlet
s that depend on the state of thisOutlet
.protected void
didInvalidateInput()
protected void
didReconcileInput(int version)
void
disconnectInputs()
Disconnects allInlet
s dominated by thisOutlet
in the dataflow dependency graph.void
disconnectOutputs()
Disconnects allOutlet
s dominated by thisOutlet
in the dataflow graph.abstract O
get()
Returns the current state of thisOutlet
.void
invalidateInput()
protected void
onInvalidateInput()
protected void
onReconcileInput(int version)
Iterator<Inlet<? super O>>
outputIterator()
Returns anIterator
over the set ofInlet
s that depend on the state of thisOutlet
.void
reconcileInput(int version)
Reconciles the state of thisOutlet
, if the version of thisOutlet
's state differs from the targetversion
.void
unbindOutput(Inlet<? super O> output)
Removes anoutput
from the set ofInlet
s that depend on the state of thisOutlet
.void
unbindOutputs()
Disconnects all outputs from thisOutlet
by invokingInlet.unbindInput()
on eachInelt
that depends on the state of thisOutlet
.protected void
willInvalidateInput()
protected void
willReconcileInput(int version)
-
-
-
Method Detail
-
get
public abstract O get()
Description copied from interface:Outlet
Returns the current state of thisOutlet
.
-
outputIterator
public Iterator<Inlet<? super O>> outputIterator()
Description copied from interface:Outlet
Returns anIterator
over the set ofInlet
s that depend on the state of thisOutlet
.- Specified by:
outputIterator
in interfaceOutlet<O>
-
bindOutput
public void bindOutput(Inlet<? super O> output)
Description copied from interface:Outlet
Adds anoutput
to the set ofInlet
s that depend on the state of thisOutlet
. Theoutput
will be invalidated when the state of thisOutlet
is invalidated, and updated when thisOutlet
is updated.- Specified by:
bindOutput
in interfaceOutlet<O>
-
unbindOutput
public void unbindOutput(Inlet<? super O> output)
Description copied from interface:Outlet
Removes anoutput
from the set ofInlet
s that depend on the state of thisOutlet
.- Specified by:
unbindOutput
in interfaceOutlet<O>
-
unbindOutputs
public void unbindOutputs()
Description copied from interface:Outlet
Disconnects all outputs from thisOutlet
by invokingInlet.unbindInput()
on eachInelt
that depends on the state of thisOutlet
.- Specified by:
unbindOutputs
in interfaceOutlet<O>
-
disconnectOutputs
public void disconnectOutputs()
Description copied from interface:Outlet
Disconnects allOutlet
s dominated by thisOutlet
in the dataflow graph. Used to recursively clean up chains of combinators originating from thisInlet
.- Specified by:
disconnectOutputs
in interfaceOutlet<O>
-
disconnectInputs
public void disconnectInputs()
Description copied from interface:Outlet
Disconnects allInlet
s dominated by thisOutlet
in the dataflow dependency graph. Used to recursively clean up chains of combinators passing through thisOutlet
.- Specified by:
disconnectInputs
in interfaceOutlet<O>
-
invalidateInput
public void invalidateInput()
Description copied from interface:Outlet
- Specified by:
invalidateInput
in interfaceOutlet<O>
-
reconcileInput
public void reconcileInput(int version)
Description copied from interface:Outlet
Reconciles the state of thisOutlet
, if the version of thisOutlet
's state differs from the targetversion
. To reconcile its state, theOutlet
first invokesStreamlet.reconcile(int)
on theStreamlet
to which it's attached. It then invokesInlet.reconcileOutput(int)
on each of its dependentoutputs
.- Specified by:
reconcileInput
in interfaceOutlet<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)
-
-