MainActor

cc.otavia.core.actor.MainActor
See theMainActor companion object
abstract class MainActor(val args: Array[String] = ...) extends StateActor[Args]

Application entry point actor. Automatically sends command-line arguments as an Args notice to self on mount.

Subclasses implement main0 to define the application logic. Note that afterMount is finalized to inject the args-sending behavior — override afterMount0 instead for custom mount-time initialization.

Value parameters

args

command-line arguments passed to the application

Attributes

Companion
object
Graph
Supertypes
class StateActor[Args]
trait Actor[Args]
class Object
trait Matchable
class Any

Members list

Value members

Abstract methods

Application entry point. Called when the Args notice is received.

Application entry point. Called when the Args notice is received.

Attributes

Concrete methods

final override def afterMount(): Unit

When a actor instance is mounted to actor system, this method will call by actor system

When a actor instance is mounted to actor system, this method will call by actor system

Attributes

Definition Classes
final override def resumeNotice(stack: NoticeStack[Args]): StackYield

Handle a Notice message. Called on initial receipt and on each resume.

Handle a Notice message. Called on initial receipt and on each resume.

Attributes

Definition Classes
AbstractActor

Inherited methods

final def actorId: Long

The unique id of this actor distributed by ActorSystem, when a actor instance is mounted to a ActorSystem, the actor system will distribute a unique id to the instance.

The unique id of this actor distributed by ActorSystem, when a actor instance is mounted to a ActorSystem, the actor system will distribute a unique id to the instance.

Attributes

Returns

id number

Inherited from:
Actor
final def autowire[A <: Actor[_] : ClassTag](qualifier: String): Address[MessageOf[A]]

Attributes

Inherited from:
Actor
final def autowire[A <: Actor[_] : ClassTag](qualifier: Option[String] = ..., remote: Option[String] = ...): Address[MessageOf[A]]

Attributes

Inherited from:
Actor
def batchable: Boolean

Whether this actor supports batch message processing. When true, the ActorSystem dispatches multiple messages in bulk rather than individually.

Whether this actor supports batch message processing. When true, the ActorSystem dispatches multiple messages in bulk rather than individually.

Attributes

Inherited from:
Actor
final override def context: ActorContext

Context of this actor. This method can only used after actor instance mount to actor system

Context of this actor. This method can only used after actor instance mount to actor system

Attributes

Definition Classes
AbstractActor -> Actor
Inherited from:
AbstractActor (hidden)
def maxBatchSize: Int

Maximum number of messages per batch. Used by the scheduling system.

Maximum number of messages per batch. Used by the scheduling system.

Attributes

Inherited from:
Actor

Attributes

Inherited from:
Actor
def nice: Int

Attributes

Inherited from:
Actor
final protected def noticeSelfHead(call: Notice & Args): Unit

Send a Notice to self, inserted at the head of the notice mailbox before all other pending notices.

Send a Notice to self, inserted at the head of the notice mailbox before all other pending notices.

Attributes

Inherited from:
AbstractActor (hidden)
protected def resumeAsk(stack: AskStack[Args & Ask[_ <: Reply]]): StackYield

Handle an Ask message. Called on initial receipt and on each resume after an awaited reply completes.

Handle an Ask message. Called on initial receipt and on each resume after an awaited reply completes.

Match on stack.state to distinguish initial entry from resumed execution:

override protected def resumeAsk(stack: AskStack[MyAsk]): StackYield =
  stack.state match
    case _: StartState =>
      val state = FutureState[MyReply]()
      address.ask(MyRequest(), state.future)
      stack.suspend(state)
    case state: FutureState[MyReply] =>
      stack.return(state.future.getNow)

Attributes

Inherited from:
AbstractActor (hidden)
protected def resumeBatchAsk(stack: BatchAskStack[Args & Ask[_ <: Reply]]): StackYield

Handle a batch of Ask messages in a single stack.

Handle a batch of Ask messages in a single stack.

Attributes

Inherited from:
AbstractActor (hidden)

Handle a batch of Notice messages in a single stack.

Handle a batch of Notice messages in a single stack.

Attributes

Inherited from:
AbstractActor (hidden)
override def self: ActorAddress[Args]

Typed self-address for this StateActor.

Typed self-address for this StateActor.

Attributes

Definition Classes
StateActor -> AbstractActor
Inherited from:
StateActor
final def system: ActorSystem

The ActorSystem of this actor instance is running

The ActorSystem of this actor instance is running

Attributes

Returns

ActorSystem

Inherited from:
Actor
final def timer: Timer

Attributes

Inherited from:
Actor

Concrete fields

val args: Array[String]

Inherited fields

val batchAskFilter: (Ask[_]) => Boolean

Filter function for batching Ask messages. Return true to include in batch.

Filter function for batching Ask messages. Return true to include in batch.

Attributes

Inherited from:
Actor
val batchNoticeFilter: Notice => Boolean

Filter function for batching Notice messages. Return true to include in batch.

Filter function for batching Notice messages. Return true to include in batch.

Attributes

Inherited from:
Actor
protected var logger: Logger

Attributes

Inherited from:
AbstractActor (hidden)