WIP Resource event handling

[aquarium] / src / main / scala / gr / grnet / aquarium / computation / state / parts / IgnoredFirstResourceEventsWorker.scala

diff --git a/src/main/scala/gr/grnet/aquarium/computation/data/IgnoredFirstResourceEventsWorker.scala b/src/main/scala/gr/grnet/aquarium/computation/state/parts/IgnoredFirstResourceEventsWorker.scala
similarity index 95%
rename from src/main/scala/gr/grnet/aquarium/computation/data/IgnoredFirstResourceEventsWorker.scala
rename to src/main/scala/gr/grnet/aquarium/computation/state/parts/IgnoredFirstResourceEventsWorker.scala
index ee640b9..aaede1a 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/computation/data/IgnoredFirstResourceEventsWorker.scala
+++ b/src/main/scala/gr/grnet/aquarium/computation/state/parts/IgnoredFirstResourceEventsWorker.scala
@@ -33,7 +33,9 @@
  * or implied, of GRNET S.A.
  */
 
-package gr.grnet.aquarium.computation.data
+package gr.grnet.aquarium.computation
+package state
+package parts
 
 import gr.grnet.aquarium.util.findAndRemoveFromMap
 import gr.grnet.aquarium.event.model.resource.ResourceEventModel
@@ -57,7 +59,7 @@ case class IgnoredFirstResourceEventsWorker(ignoredFirstEventsMap: FullMutableRe
 
   def size = ignoredFirstEventsMap.size
 
-  def foreach[U](f: ResourceEventModel => U): Unit = {
+  def foreach[U](f: ResourceEventModel ⇒ U): Unit = {
     ignoredFirstEventsMap.valuesIterator.foreach(f)
   }
 }