akka.stream.impl

ExpandImpl

class ExpandImpl 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. ExpandImpl
  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 ExpandImpl(_settings: MaterializerSettings, seed: (Any) ⇒ Any, extrapolate: (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 ExpandImpl to any2stringadd[ExpandImpl] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (ExpandImpl, B)

    Implicit information
    This member is added by an implicit conversion from ExpandImpl to ArrowAssoc[ExpandImpl] 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. implicit val context: ActorContext

    Definition Classes
    Actor
  15. def emitExtrapolate(): Unit

  16. val emitFirst: TransferPhase

  17. def ensuring(cond: (ExpandImpl) ⇒ Boolean, msg: ⇒ Any): ExpandImpl

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

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

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

    Implicit information
    This member is added by an implicit conversion from ExpandImpl to Ensuring[ExpandImpl] 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. val extrapolateOrReset: TransferPhase

  24. var extrapolateState: Any

  25. def fail(e: Throwable): Unit

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

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

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

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

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

    Definition Classes
    Any
  31. final def isPumpFinished: Boolean

    Definition Classes
    Pump
  32. def log: LoggingAdapter

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

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

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

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

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

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

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

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

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

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

    Attributes
    protected
    Definition Classes
    ActorProcessorImpl
  43. val primaryOutputs: FanoutOutputs

    Attributes
    protected
    Definition Classes
    ActorProcessorImpl
  44. var primaryOutputsShutdown: Boolean

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

    Definition Classes
    Pump
  46. val pumpContext: ActorContext

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

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

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

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

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

    Definition Classes
    Actor
  52. val settings: MaterializerSettings

    Definition Classes
    ActorProcessorImpl
  53. def shutdownHooks(): Unit

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

    Definition Classes
    SoftShutdown
  55. def supervisorStrategy: SupervisorStrategy

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

    Definition Classes
    AnyRef
  57. def toString(): String

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

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

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  62. val waitFirst: TransferPhase

  63. def [B](y: B): (ExpandImpl, B)

    Implicit information
    This member is added by an implicit conversion from ExpandImpl to ArrowAssoc[ExpandImpl] 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 ExpandImpl to any2stringadd[ExpandImpl]

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

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

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

Ungrouped