FirstState

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. def andThenPresent[D](present2: (State) ⇒ D): MonoidAggregator[Event[State], (Long, features.types.State.Value), D]

   

   Definition Classes

   MonoidAggregator → Aggregator

5. def append(l: (Long, features.types.State.Value), r: Event[State]): (Long, features.types.State.Value)

   

   Definition Classes

   Aggregator

6. def appendAll(items: TraversableOnce[Event[State]]): (Long, features.types.State.Value)

   

   Definition Classes

   MonoidAggregator

7. def appendAll(old: (Long, features.types.State.Value), items: TraversableOnce[Event[State]]): (Long, features.types.State.Value)

   

   Definition Classes

   Aggregator

8. def apply(inputs: TraversableOnce[Event[State]]): State

   

   Definition Classes

   Aggregator

9. def applyCumulatively[In <: TraversableOnce[Event[State]], Out](inputs: In)(implicit bf: CanBuildFrom[In, State, Out]): Out

   

   Definition Classes

   Aggregator

10. def applyOption(inputs: TraversableOnce[Event[State]]): Option[State]

    

    Definition Classes

    Aggregator

11. final def asInstanceOf[T0]: T0

    

    Definition Classes

    Any

12. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

13. def collectBefore[A2](fn: PartialFunction[A2, Event[State]]): MonoidAggregator[A2, (Long, features.types.State.Value), State]

    

    Definition Classes

    MonoidAggregator

14. def composePrepare[A2](prepare2: (A2) ⇒ Event[State]): MonoidAggregator[A2, (Long, features.types.State.Value), State]

    

    Definition Classes

    MonoidAggregator → Aggregator

15. def cumulativeIterator(inputs: Iterator[Event[State]]): Iterator[State]

    

    Definition Classes

    Aggregator

16. def either[A2, B2, C2](that: MonoidAggregator[A2, B2, C2]): MonoidAggregator[Either[Event[State], A2], ((Long, features.types.State.Value), B2), (State, C2)]

    

    Definition Classes

    MonoidAggregator

17. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

18. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

19. def filterBefore[A1 <: Event[State]](pred: (A1) ⇒ Boolean): MonoidAggregator[A1, (Long, features.types.State.Value), State]

    

    Definition Classes

    MonoidAggregator

20. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

21. val ftFactory: FeatureTypeFactory[State]

    

    Definition Classes

    TimeBasedAggregator

22. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

23. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

24. def join[A2 <: Event[State], B2, C2](that: Aggregator[A2, B2, C2]): Aggregator[A2, ((Long, features.types.State.Value), B2), (State, C2)]

    

    Definition Classes

    Aggregator

25. def lift: MonoidAggregator[Event[State], Option[(Long, features.types.State.Value)], Option[State]]

    

    Definition Classes

    Aggregator

26. val monoid: Monoid[(Long, features.types.State.Value)]

    

    Definition Classes

    TimeBasedAggregator → MonoidAggregator

27. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

28. final def notify(): Unit

    

    Definition Classes

    AnyRef

29. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

30. def prepare(input: Event[State]): (Long, features.types.State.Value)

    

    Definition Classes

    TimeBasedAggregator → Aggregator

31. def present(reduction: (Long, features.types.State.Value)): State

    

    Definition Classes

    TimeBasedAggregator → Aggregator

32. final def reduce(items: TraversableOnce[(Long, features.types.State.Value)]): (Long, features.types.State.Value)

    

    Definition Classes

    MonoidAggregator → Aggregator

33. def reduce(l: (Long, features.types.State.Value), r: (Long, features.types.State.Value)): (Long, features.types.State.Value)

    

    Definition Classes

    Aggregator

34. def reduceOption(items: TraversableOnce[(Long, features.types.State.Value)]): Option[(Long, features.types.State.Value)]

    

    Definition Classes

    Aggregator

35. def semigroup: Monoid[(Long, features.types.State.Value)]

    

    Definition Classes

    MonoidAggregator → Aggregator

36. def sumBefore: MonoidAggregator[TraversableOnce[Event[State]], (Long, features.types.State.Value), State]

    

    Definition Classes

    MonoidAggregator

37. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

38. val timeZero: Long

    

    Definition Classes

    TimeBasedAggregator

39. def toFold: Fold[Event[State], Option[State]]

    

    Definition Classes

    Aggregator

40. implicit val ttag: scala.reflect.api.JavaUniverse.WeakTypeTag[State]

    

    Definition Classes

    TimeBasedAggregator

41. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

42. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

43. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

44. def zip[A2, B2, C2](ag2: MonoidAggregator[A2, B2, C2]): MonoidAggregator[(Event[State], A2), ((Long, features.types.State.Value), B2), (State, C2)]

    

    Definition Classes

    MonoidAggregator

45. def zip[A2, B2, C2](ag2: Aggregator[A2, B2, C2]): Aggregator[(Event[State], A2), ((Long, features.types.State.Value), B2), (State, C2)]

    

    Definition Classes

    Aggregator