class Movie::Remote::RemoteAskResponseSenderRef

Included Modules

Defined in:

movie/remote/extension.cr

Constant Summary

ASK_CANCELLED_TAG = "__movie_remote_ask_cancelled__"
ASK_FAILURE_TAG = "__movie_remote_ask_failure__"

Constructors

Instance Method Summary

Instance methods inherited from module Movie::Remote::RemotePeerIdentity

remote_address : Address | Nil remote_address, remote_node_uid : String | Nil remote_node_uid

Instance methods inherited from class Movie::ActorRefBase

id : Int32 id, path : ActorPath | Nil path, path=(path : ActorPath | Nil) path=, remote_peer_address : Address | Nil remote_peer_address, remote_peer_node_uid : String | Nil remote_peer_node_uid, send_system(message : SystemMessage) send_system

Constructor methods inherited from class Movie::ActorRefBase

new(id : Int32, path : ActorPath | Nil = nil) new

Constructor Detail

def self.new(connection : InboundConnection, correlation_id : String, path : ActorPath | Nil) #

[View source]

Instance Method Detail

def remote_address : Address | Nil #

[View source]
def remote_node_uid : String | Nil #

[View source]
def remote_peer_address : Address | Nil #
Description copied from class Movie::ActorRefBase

Authenticated transport identity for inbound remote sender refs.


[View source]
def remote_peer_node_uid : String | Nil #

[View source]
def reply_cancelled : Nil #

[View source]
def reply_failure(error : Exception) : Nil #

[View source]
def reply_success(value : JSON::Serializable) : Nil #

[View source]
def send_system(message : Movie::SystemMessage) #

[View source]