Packages

p

com.mfglabs

stream

package stream

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. case class Debounce [T](per: FiniteDuration, toHash: (T) ⇒ String) extends GraphStage[FlowShape[T, Debounced[T]]] with Product with Serializable

    Implementation of a Debouncer The precision is not great, something around ~100ms It does not drop elements but wrap it in one of two classes

    Implementation of a Debouncer The precision is not great, something around ~100ms It does not drop elements but wrap it in one of two classes

    • Debounced.Ok: the elemnt was not seen since at least per duration.
    • Debounced.Ko: the elemnt was seen less than per duration ago.
  2. sealed trait Debounced [T] extends AnyRef
  3. final case class ExecutionContextForBlockingOps (value: ExecutionContext) extends AnyVal with Product with Serializable
  4. trait FlowExt extends AnyRef
  5. trait SourceExt extends AnyRef

Value Members

  1. object Debounced
  2. object FlowExt extends FlowExt
  3. object SourceExt extends SourceExt

Ungrouped