class Movie::Remote::InboundConnection

• Movie::Remote::InboundConnection
• Reference
• Object

Overview

InboundConnection handles an incoming connection from a remote system.

Defined in:

Constant Summary

Log = ::Log.for(self)

Constructors

• .new(socket : TCPSocket, transport : IO, server : Server, path_registry : Movie::PathRegistry, local_system : String, local_address : Proc(Address), node_uid : String, control_deduplicator : ControlDeduplicator, on_message : Proc(WireEnvelope, InboundConnection, Nil), shared_secret : String | Nil = nil, heartbeat_interval : Time::Span = 1.second, heartbeat_timeout : Time::Span = 5.seconds)

Instance Method Summary

• #close

  Closes the connection.

• #close_without_callback

  Closes the connection without notifying the server (used during server shutdown).

• #connected? : Bool
• #drain_watches : Array(Tuple(Movie::ActorRefBase, Movie::ActorRefBase))
• #remote_address : Address | Nil

  Returns the remote address if known (from handshake).

• #remote_address=(remote_address : Address | Nil)

  Sets the remote address (from handshake).

• #remote_node_uid : String | Nil

  The process incarnation authenticated by the association handshake.

• #send(envelope : WireEnvelope) : Bool

  Sends an envelope to the remote system.

• #start

  Starts reading from the connection.

• #track_watch(target : Movie::ActorRefBase, watcher : Movie::ActorRefBase) : Nil
• #untrack_watch(target : Movie::ActorRefBase, watcher : Movie::ActorRefBase) : Nil

Constructor Detail

Instance Method Detail