class Movie::Remote::RemoteActorRef(T)

• Movie::Remote::RemoteActorRef(T)
• Movie::ActorRefBase
• Reference
• Object

Overview

RemoteActorRef provides a type-safe reference to an actor in a remote system. Messages sent through this reference are serialized and transmitted over TCP. Uses striped connection pools for parallel sending while preserving per-actor ordering.

Defined in:

Constant Summary

Log = ::Log.for(self)

Constructors

• .new(system : Movie::AbstractActorSystem, pool : StripedConnectionPool, target_path : ActorPath, path_registry : Movie::PathRegistry)

Instance Method Summary

• #<<(message : T)

  Sends a message to the remote actor (fire-and-forget).

• #==(other : Movie::ActorRefBase) : Bool
• #ask(message : T, response_type : R.class, timeout : Time::Span = 30.seconds) : Movie::Future(R) forall R

  Performs an ask (request-reply) to the remote actor.

• #ask_serializable(message : T, timeout : Time::Span = 30.seconds) : Movie::Future(JSON::Serializable)

  Internal dynamic ask used by protocol coordinators that must relay a registered response without knowing its concrete type at compile time.

• #connection : Connection

  Returns the connection being used for this actor ref.

• #hash(hasher)

  See Object#hash(hasher)

• #send_system(message : Movie::SystemMessage)

  Sends a system message to the remote actor.

• #target_path : ActorPath
• #tell_from(sender : Movie::ActorRefBase | Nil, message : T)

  Sends a message to the remote actor with sender information.

• #tell_unordered(message : T)

  Sends a message without ordering guarantee (uses round-robin for load balancing).

Constructor Detail

Instance Method Detail