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

   This member is added by an implicit conversion from FanIn to any2stringadd[FanIn] performed by method any2stringadd in scala.Predef.

   Definition Classes

   any2stringadd

4.  def ->[B](y: B): (FanIn, B)

   Implicit

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

   Can be overridden to intercept calls to postRestart.

   Can be overridden to intercept calls to postRestart. Calls postRestart by default.

   Attributes

   protected[akka]

   Definition Classes

   Actor

7.  def aroundPostStop(): Unit

   Can be overridden to intercept calls to postStop.

   Can be overridden to intercept calls to postStop. Calls postStop by default.

   Attributes

   protected[akka]

   Definition Classes

   Actor

8.  def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

   Can be overridden to intercept calls to preRestart.

   Can be overridden to intercept calls to preRestart. Calls preRestart by default.

   Attributes

   protected[akka]

   Definition Classes

   Actor

9.  def aroundPreStart(): Unit

   Can be overridden to intercept calls to preStart.

   Can be overridden to intercept calls to preStart. Calls preStart by default.

   Attributes

   protected[akka]

   Definition Classes

   Actor

10.  def aroundReceive(receive: actor.Actor.Receive, msg: Any): Unit

    INTERNAL API.

    INTERNAL API.

    Can be overridden to intercept calls to this actor's current behavior.

    receive

    current behavior.

    msg

    current message.

    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

    Stores the context for this actor, including self, and sender.

    Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

    WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

    akka.actor.ActorContext is the Scala API. getContext returns a akka.actor.UntypedActorContext, which is the Java API of the actor context.

    Definition Classes

    Actor

15.  def ensuring(cond: (FanIn) ⇒ Boolean, msg: ⇒ Any): FanIn

    Implicit

    This member is added by an implicit conversion from FanIn to Ensuring[FanIn] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

16.  def ensuring(cond: (FanIn) ⇒ Boolean): FanIn

    Implicit

    This member is added by an implicit conversion from FanIn to Ensuring[FanIn] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

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

    Implicit

    This member is added by an implicit conversion from FanIn to Ensuring[FanIn] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

18.  def ensuring(cond: Boolean): FanIn

    Implicit

    This member is added by an implicit conversion from FanIn to Ensuring[FanIn] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

19.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

20.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

21.  def fail(e: Throwable): Unit

    Attributes

    protected

22.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

23.  def formatted(fmtstr: String): String

    Implicit

    This member is added by an implicit conversion from FanIn to StringFormat[FanIn] performed by method StringFormat in scala.Predef.

    Definition Classes

    StringFormat

    Annotations

    @inline()

24.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

25.  def gotUpstreamSubscription(): Unit

    Definition Classes

    Pump

26.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

27.  final def initialPhase(waitForUpstream: Int, andThen: TransferPhase): Unit

    Definition Classes

    Pump

28.  val inputBunch: InputBunch

    Attributes

    protected

29.  val inputCount: Int
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 postRestart(reason: Throwable): Unit

    User overridable callback: By default it calls preStart().

    User overridable callback: By default it calls preStart().

    reason

    the Throwable that caused the restart to happen Is called right AFTER restart on the newly created Actor to allow reinitialization after an Actor crash.

    Definition Classes

    FanIn → Actor

38.  def postStop(): Unit

    User overridable callback.

    User overridable callback.

    Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

    Definition Classes

    FanIn → Actor

39.  def preRestart(reason: Throwable, message: Option[Any]): Unit

    User overridable callback: By default it disposes of all children and then calls postStop().

    User overridable callback: By default it disposes of all children and then calls postStop().

    reason

    the Throwable that caused the restart to happen

    message

    optionally the current message the actor processed when failing, if applicable Is called on a crashed Actor right BEFORE it is restarted to allow clean up of resources before Actor is terminated.

    Definition Classes

    Actor

    Annotations

    @throws( classOf[Exception] )

40.  def preStart(): Unit

    User overridable callback.

    User overridable callback.

    Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.

    Definition Classes

    Actor

    Annotations

    @throws( classOf[Exception] )

41.  val primaryOutputs: Outputs

    Attributes

    protected

42.  final def pump(): Unit

    Definition Classes

    Pump

43.  def pumpFailed(e: Throwable): Unit

    Definition Classes

    FanIn → Pump

44.  def pumpFinished(): Unit

    Definition Classes

    FanIn → Pump

45.  def receive: PartialFunction[Any, Unit]

    This defines the initial actor behavior, it must return a partial function with the actor logic.

    This defines the initial actor behavior, it must return a partial function with the actor logic.

    Definition Classes

    FanIn → Actor

46.  implicit final val self: ActorRef

    The 'self' field holds the ActorRef for this actor.

    The 'self' field holds the ActorRef for this actor.

    Can be used to send messages to itself:

    self ! message
    

    Definition Classes

    Actor

47.  final def sender(): ActorRef

    The reference sender Actor of the last received message.

    The reference sender Actor of the last received message. Is defined if the message was sent from another Actor, else deadLetters in akka.actor.ActorSystem.

    WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

    Definition Classes

    Actor

48.  val settings: ActorMaterializerSettings
49.  def supervisorStrategy: SupervisorStrategy

    User overridable definition the strategy to use for supervising child actors.

    User overridable definition the strategy to use for supervising child actors.

    Definition Classes

    Actor

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

    Definition Classes

    AnyRef

51.  def toString(): String

    Definition Classes

    AnyRef → Any

52.  def unhandled(message: Any): Unit

    User overridable callback.

    User overridable callback.

    Is called when a message isn't handled by the current behavior of the actor by default it fails with either a akka.actor.DeathPactException (in case of an unhandled akka.actor.Terminated message) or publishes an akka.actor.UnhandledMessage to the actor's system's akka.event.EventStream

    Definition Classes

    Actor

53.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

55.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

56.  final def waitForUpstreams(waitForUpstream: Int): Unit

    Definition Classes

    Pump

57.  def →[B](y: B): (FanIn, B)

    Implicit

    This member is added by an implicit conversion from FanIn to ArrowAssoc[FanIn] performed by method ArrowAssoc in scala.Predef.

    Definition Classes

    ArrowAssoc