akka.stream.impl

BufferImpl

class BufferImpl 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. BufferImpl
  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 BufferImpl(_settings: MaterializerSettings, size: Int, overflowStrategy: OverflowStrategy)

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 BufferImpl to any2stringadd[BufferImpl] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (BufferImpl, B)

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

  13. val bufferEmpty: TransferPhase

  14. val bufferFull: TransferPhase

  15. val bufferNonEmpty: TransferPhase

  16. def clone(): AnyRef

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

    Attributes
    protected
    Definition Classes
    Pump
  18. implicit val context: ActorContext

    Definition Classes
    Actor
  19. val dropAction: () ⇒ Unit

  20. def ensuring(cond: (BufferImpl) ⇒ Boolean, msg: ⇒ Any): BufferImpl

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

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

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

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

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

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

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

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

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

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

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

    Definition Classes
    Any
  32. final def isPumpFinished: Boolean

    Definition Classes
    Pump
  33. def log: LoggingAdapter

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

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

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

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

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

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

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

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

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

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

    Attributes
    protected
    Definition Classes
    ActorProcessorImpl
  44. val primaryOutputs: FanoutOutputs

    Attributes
    protected
    Definition Classes
    ActorProcessorImpl
  45. var primaryOutputsShutdown: Boolean

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

    Definition Classes
    Pump
  47. val pumpContext: ActorContext

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

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

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

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

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

    Definition Classes
    Actor
  53. val settings: MaterializerSettings

    Definition Classes
    ActorProcessorImpl
  54. def shutdownHooks(): Unit

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

    Definition Classes
    SoftShutdown
  56. def supervisorStrategy: SupervisorStrategy

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

    Definition Classes
    AnyRef
  58. def toString(): String

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

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

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  63. def [B](y: B): (BufferImpl, B)

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

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

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

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

Ungrouped