Esper event time

esper_event_time.scala

// Assume the esper clock has been seeded with the vimana system time on start 
// and is being updated via the DeviceActor every 100ms when no agent is connected

// Someplace earlier in the class
var lastEvent: Option[Event] = None

for (event <- events) {
  lastEvent filter (event.timestamp > _.timestamp) foreach {
    esper.advanceClock(event.timestamp - _.timestamp)
  }
  lastEvent = Some(event)
  esper.send(event)
}

// ...when the agent disconnects
lastEvent = None