akka.stream.impl

ConflateImpl

class ConflateImpl extends ActorProcessorImpl

Source
RateDetachedProcessors.scala
Linear Supertypes
ActorProcessorImpl, Pump, SoftShutdown, ActorLogging, Actor, AnyRef, Any
Type Hierarchy Learn more about scaladoc diagrams
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ConflateImpl
  2. ActorProcessorImpl
  3. Pump
  4. SoftShutdown
  5. ActorLogging
  6. Actor
  7. AnyRef
  8. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ConflateImpl(_settings: MaterializerSettings, seed: (Any) ⇒ Any, aggregate: (Any, Any) ⇒ Any)

Type Members

  1. type Receive = PartialFunction[Any, Unit]

    Definition Classes
    Actor

Value Members

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

    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Definition Classes
    AnyRef → Any
  3. def +(other: String): String

    Implicit information
    This member is added by an implicit conversion from ConflateImpl to any2stringadd[ConflateImpl] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (ConflateImpl, B)

    Implicit information
    This member is added by an implicit conversion from ConflateImpl to ArrowAssoc[ConflateImpl] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  6. def aroundPostRestart(reason: Throwable): Unit

    Attributes
    protected[akka]
    Definition Classes
    Actor
  7. def aroundPostStop(): Unit

    Attributes
    protected[akka]
    Definition Classes
    Actor
  8. def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

    Attributes
    protected[akka]
    Definition Classes
    Actor
  9. def aroundPreStart(): Unit

    Attributes
    protected[akka]
    Definition Classes
    Actor
  10. def aroundReceive(receive: actor.Actor.Receive, msg: Any): Unit

    Attributes
    protected[akka]
    Definition Classes
    Actor
  11. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  12. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  13. final val completedPhase: TransferPhase

    Attributes
    protected
    Definition Classes
    Pump
  14. val conflateThenEmit: TransferPhase

  15. var conflated: Any

  16. implicit val context: ActorContext

    Definition Classes
    Actor
  17. def ensuring(cond: (ConflateImpl) ⇒ Boolean, msg: ⇒ Any): ConflateImpl

    Implicit information
    This member is added by an implicit conversion from ConflateImpl to Ensuring[ConflateImpl] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  18. def ensuring(cond: (ConflateImpl) ⇒ Boolean): ConflateImpl

    Implicit information
    This member is added by an implicit conversion from ConflateImpl to Ensuring[ConflateImpl] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  19. def ensuring(cond: Boolean, msg: ⇒ Any): ConflateImpl

    Implicit information
    This member is added by an implicit conversion from ConflateImpl to Ensuring[ConflateImpl] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  20. def ensuring(cond: Boolean): ConflateImpl

    Implicit information
    This member is added by an implicit conversion from ConflateImpl to Ensuring[ConflateImpl] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  21. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  22. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  23. def fail(e: Throwable): Unit

    Attributes
    protected
    Definition Classes
    ActorProcessorImpl
  24. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  25. def formatted(fmtstr: String): String

    Implicit information
    This member is added by an implicit conversion from ConflateImpl to StringFormat[ConflateImpl] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  26. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  27. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  28. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  29. final def isPumpFinished: Boolean

    Definition Classes
    Pump
  30. def log: LoggingAdapter

    Definition Classes
    ActorLogging
  31. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  32. final def nextPhase(phase: TransferPhase): Unit

    Definition Classes
    Pump
  33. final def notify(): Unit

    Definition Classes
    AnyRef
  34. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  35. def onError(e: Throwable): Unit

    Attributes
    protected
    Definition Classes
    ActorProcessorImpl
  36. def postRestart(reason: Throwable): Unit

    Definition Classes
    Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  37. def postStop(): Unit

    Definition Classes
    ActorProcessorImpl → Actor
  38. def preRestart(reason: Throwable, message: Option[Any]): Unit

    Definition Classes
    ActorProcessorImpl → Actor
  39. def preStart(): Unit

    Definition Classes
    Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  40. val primaryInputs: Inputs

    Attributes
    protected
    Definition Classes
    ActorProcessorImpl
  41. val primaryOutputs: FanoutOutputs

    Attributes
    protected
    Definition Classes
    ActorProcessorImpl
  42. var primaryOutputsShutdown: Boolean

    Definition Classes
    ActorProcessorImpl
  43. final def pump(): Unit

    Definition Classes
    Pump
  44. val pumpContext: ActorContext

    Definition Classes
    ActorProcessorImpl → Pump
  45. def pumpFailed(e: Throwable): Unit

    Definition Classes
    ActorProcessorImpl → Pump
  46. def pumpFinished(): Unit

    Definition Classes
    ActorProcessorImpl → Pump
  47. def receive: PartialFunction[Any, Unit]

    Definition Classes
    ActorProcessorImpl → Actor
  48. implicit final val self: ActorRef

    Definition Classes
    Actor
  49. final def sender(): ActorRef

    Definition Classes
    Actor
  50. val settings: MaterializerSettings

    Definition Classes
    ActorProcessorImpl
  51. def shutdownHooks(): Unit

    Attributes
    protected
    Definition Classes
    ActorProcessorImpl
  52. def softShutdown(): Unit

    Definition Classes
    SoftShutdown
  53. def supervisorStrategy: SupervisorStrategy

    Definition Classes
    Actor
  54. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  55. def toString(): String

    Definition Classes
    AnyRef → Any
  56. def unhandled(message: Any): Unit

    Definition Classes
    Actor
  57. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  58. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  59. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  60. val waitNextZero: TransferPhase

  61. def [B](y: B): (ConflateImpl, B)

    Implicit information
    This member is added by an implicit conversion from ConflateImpl to ArrowAssoc[ConflateImpl] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Inherited from ActorProcessorImpl

Inherited from Pump

Inherited from SoftShutdown

Inherited from ActorLogging

Inherited from Actor

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from ConflateImpl to any2stringadd[ConflateImpl]

Inherited by implicit conversion StringFormat from ConflateImpl to StringFormat[ConflateImpl]

Inherited by implicit conversion Ensuring from ConflateImpl to Ensuring[ConflateImpl]

Inherited by implicit conversion ArrowAssoc from ConflateImpl to ArrowAssoc[ConflateImpl]

Ungrouped