interpreter
API
Generated with
interpreter/de.uni_luebeck.isp.tessla.interpreter/StreamEngine

StreamEngine

de.uni_luebeck.isp.tessla.interpreter.StreamEngine
See theStreamEngine companion object
class StreamEngine(unitValue: Any)

Evaluates a stream graph synchronously. In each evaluation cycle inputs are supplied with values. Then.input and delay nodes are triggered to initiate the propagation of values. Listeners can be registered to receive results at output streams.

Attributes

Companion:
object
Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Concise view

Type members

Classlikes

final class Input extends Triggered

Attributes

Graph
Supertypes
class Triggered
class Stream
class Object
trait Matchable
class Any
sealed class Stream

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes
class Triggered
class Input
Self type
sealed abstract class Triggered extends Stream

Attributes

Graph
Supertypes
class Stream
class Object
trait Matchable
class Any
Known subtypes
class Input

Value members

Concrete methods

def delay(delays: => Stream, resets: => Stream): Stream
def last(values: => Stream, times: Stream): Stream
def lift(streams: ArraySeq[Stream])(op: ArraySeq[Option[Any]] => Option[Any]): Stream
def merge(streams: ArraySeq[Stream]): Stream
def nil: Stream
def slift(streams: ArraySeq[Stream])(op: ArraySeq[Any] => Any): Stream
def step(): Unit

Propagates all inputs without progressing time. Can only be called once per point in time. No more input values can be provided for the current time afterwards.

Propagates all inputs without progressing time. Can only be called once per point in time. No more input values can be provided for the current time afterwards.

Attributes

def step(timeDelta: Time): Unit

Propagates all inputs and progresses time.

Propagates all inputs and progresses time.

Attributes

Generated with