class

Movie::Remote::Connection

Inherits Reference < Object

Connection manages an outbound TCP connection to a remote actor system.

Constants

Log = ::Log.for(self)

Constructors

new(address : Address, path_registry : Movie::PathRegistry, system : Movie::AbstractActorSystem, on_message : Proc(WireEnvelope, Nil) | Nil = nil)
Source

Instance methods

address
Source
close

Closes the connection.

Source
closed?
Source
connect

Connects to the remote system.

Source
connected?
Source
register_pending_ask(correlation_id : String) : Channel(WireEnvelope)

Registers a pending ask request and returns the channel to wait on.

Source
remove_pending_ask(correlation_id : String)

Removes a pending ask (e.g., on timeout).

Source
send(envelope : WireEnvelope) : Bool

Sends an envelope to the remote system.

Source