Class EnvironmentSubscriptionMonitor
-
- All Implemented Interfaces:
-
it.unibo.alchemist.boundary.OutputMonitor
,java.io.Serializable
public final class EnvironmentSubscriptionMonitor<T extends Object, P extends Position<out P>> implements OutputMonitor<T, P>
An OutputMonitor that emits a new Environment as a EnvironmentSurrogate each time the OutputMonitor.stepDone function is called.
-
-
Field Summary
Fields Modifier and Type Field Description private final Flow<EnvironmentSurrogate<T, P>>
eventFlow
-
Constructor Summary
Constructors Constructor Description EnvironmentSubscriptionMonitor()
-
Method Summary
Modifier and Type Method Description final Flow<EnvironmentSurrogate<T, P>>
getEventFlow()
Unit
stepDone(Environment<T, P> environment, Actionable<T> reaction, Time time, Long step)
Unit
finished(Environment<T, P> environment, Time time, Long step)
Unit
initialized(Environment<T, P> environment)
-
-
Method Detail
-
getEventFlow
final Flow<EnvironmentSurrogate<T, P>> getEventFlow()
-
stepDone
Unit stepDone(Environment<T, P> environment, Actionable<T> reaction, Time time, Long step)
-
initialized
Unit initialized(Environment<T, P> environment)
-
-
-
-