A
- the type of values produced by this signal sourcepublic class Delay<A> extends CompilableStoredSignalSource<A> implements Register
Process.Proxy
out, valueClass
STREAM_CHARACTERISTICS, STREAM_SIZE
Constructor and Description |
---|
Delay(Class<? super A> valueClass,
A initial)
Creates a new instance without a valid input source.
|
Delay(Class<? super A> valueClass,
A initial,
Function<? super Delay<A>,? extends SignalSource<A>> in)
Creates a new instance with a feedback-looped input source.
|
Delay(Class<? super A> valueClass,
A initial,
SignalSource<A> in)
Creates a new instance with an independent input source.
|
Modifier and Type | Method and Description |
---|---|
Consumer<CompilationContext> |
compileControlFlow()
Compiles the state transition of this entity.
|
Consumer<CompilationContext> |
compileGetNextValue()
Returns a code generator for loading the next value of the compiled
version of this component on the operand stack.
|
Consumer<CompilationContext> |
compileInitialization()
Compiles the initialization of this entity.
|
Consumer<CompilationContext> |
compileSetNextValue(Consumer<CompilationContext> value)
Returns a code generator for storing the next value of the compiled
version of this component from the operand stack.
|
Process |
getLoadPhase() |
A |
getNextValue()
Returns the value that will be produced on the next clock tick.
|
protected VariableContext.Variable |
getNextVariable(CompilationContext context) |
Process |
getStorePhase() |
void |
init()
Initializes the state of this process.
|
void |
setInput(SignalSource<A> in) |
void |
setNextValue(A next)
Sets the value that will be produced on the next clock tick.
|
void |
step(RealtimeContext context)
Signals a time event, executing a transition step for this process to the
next observable state.
|
compileDataFlow, compileSetStoredValueVariable, getStoredValueVariable, publishStoredValueVariable
get, getValueClass
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
andMeanwhile, andMeanwhile
adHoc, after, compile, cycle, during, ofSpliterator, ofStream, ofStream, spliterator, stream
choose, choose, choose, choose, clock, compileMainSignalSource, constant, constant, delayed, delayed, delayedFeedback, delayedFeedback, eq, getConstant, guard, hasConstant, invariant, map, map, neq, power, probe, relateWith, sampleAndHold, stored, zipWith
compileDataFlowTo, hasDataFlowIO
afterEvery, andThen, compileAsMainProcess, every, getProcess, hasControlFlowIO, hasInitializationIO, probe, sequence, sequence
public Delay(Class<? super A> valueClass, A initial)
setInput(eu.bandm.sig.adlib2.SignalSource<A>)
must be invoked before this signal
source can be used.initial
- the initial value of this signal sourcepublic Delay(Class<? super A> valueClass, A initial, SignalSource<A> in)
initial
- the initial value of this signal sourcein
- the input signal sourcepublic Delay(Class<? super A> valueClass, A initial, Function<? super Delay<A>,? extends SignalSource<A>> in)
initial
- the initial value of this signal sourcein
- a function that constructs the input signal source when
applied to this delayed signal sourcepublic void setInput(SignalSource<A> in)
public Process getLoadPhase()
getLoadPhase
in interface Register
public Process getStorePhase()
getStorePhase
in interface Register
public void init()
Process
Process.step(RealtimeContext)
transitions to
the first specified observable state.
The default implementation does nothing.
public void step(RealtimeContext context)
Process
The state of the process after successful completion of this method
should be the n-th observable state, if Process.step(eu.bandm.sig.adlib2.RealtimeContext)
has been
invoked n times since the last initialization via Process.init()
.
The behavior of this method is unspecified if Process.init()
has not been
invoked before.
If this method completes abruptly by throwing an error or unchecked exception, the process state should be considered invalid.
protected VariableContext.Variable getNextVariable(CompilationContext context)
public Consumer<CompilationContext> compileInitialization()
CompilableControlFlow
compileInitialization
in interface CompilableControlFlow
compileInitialization
in interface Process
compileInitialization
in class CompilableStoredSignalSource<A>
Process.hasInitializationIO(eu.bandm.sig.adlib2.compile.CompilationContext)
public Consumer<CompilationContext> compileControlFlow()
CompilableControlFlow
compileControlFlow
in interface CompilableControlFlow
compileControlFlow
in interface Process
compileControlFlow
in class CompilableStoredSignalSource<A>
Process.hasControlFlowIO(eu.bandm.sig.adlib2.compile.CompilationContext)
public A getNextValue()
This method is in concurrent reader–writer conflict with the getStorePhase()
process.
public Consumer<CompilationContext> compileGetNextValue()
getNextValue()
public void setNextValue(A next)
This method is in concurrent writer–writer conflict with the
getStorePhase()
process.
public Consumer<CompilationContext> compileSetNextValue(Consumer<CompilationContext> value)
setNextValue(A)