module
Movie::Ask
Defined in:
movie/ask.crClass Method Summary
- .cancel(sender : ActorRefBase | Nil, response_type : T.class) forall T
- .cancel_dynamic_if_asked(sender : ActorRefBase | Nil) : Nil
- .fail_dynamic_if_asked(sender : ActorRefBase | Nil, error : Exception) : Nil
-
.fail_if_asked(sender : ActorRefBase | Nil, error : Exception, response_type : T.class) forall T
Best-effort failure reply that only responds when the sender is an ask endpoint.
- .failure(sender : ActorRefBase | Nil, error : Exception, response_type : T.class) forall T
-
.local(system : AbstractActorSystem, target : ActorRef(M), message : M, response_type : R.class = Nil, timeout : Time::Span | Nil = nil) : Future(R) forall M, R
Creates a local ask without spawning a temporary actor.
-
.reply_if_asked(sender : ActorRefBase | Nil, value : T) forall T
Best-effort reply that only responds when the sender is an ask endpoint.
- .reply_serializable_if_asked(sender : ActorRefBase | Nil, value : JSON::Serializable) : Nil
- .success(sender : ActorRefBase | Nil, value : T) forall T
Class Method Detail
def self.fail_dynamic_if_asked(sender : ActorRefBase | Nil, error : Exception) : Nil
#
def self.fail_if_asked(sender : ActorRefBase | Nil, error : Exception, response_type : T.class) forall T
#
Best-effort failure reply that only responds when the sender is an ask endpoint.
def self.failure(sender : ActorRefBase | Nil, error : Exception, response_type : T.class) forall T
#
def self.local(system : AbstractActorSystem, target : ActorRef(M), message : M, response_type : R.class = Nil, timeout : Time::Span | Nil = nil) : Future(R) forall M, R
#
Creates a local ask without spawning a temporary actor.
def self.reply_if_asked(sender : ActorRefBase | Nil, value : T) forall T
#
Best-effort reply that only responds when the sender is an ask endpoint.
def self.reply_serializable_if_asked(sender : ActorRefBase | Nil, value : JSON::Serializable) : Nil
#