HttpServerWorker

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)

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.

Alias for self — the typed address of this IO-capable actor.

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

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

handle AcceptedChannel message, this method will called by resumeAsk

Optional ChannelInitializer for pipeline setup. Override to provide a default handler.

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

Factory method to create a new Channel instance. Override to specify the channel type.

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

Handle a batch of Ask messages in a single stack.

Handle a batch of Notice messages in a single stack.

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

Typed self-address. Separated from Actor by the +M/Address[-M] variance conflict.

The ActorSystem of this actor instance is running

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

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