class

Obsctl::IPC::ClientSession

Thread-safe message wrapper around one connected Unix socket.

Constructors

new(socket : UNIXSocket, codec : Codec = Codec.new)

Creates a session over an accepted or connected Unix socket.

Closes the underlying socket if it is still open.

read_message

Reads and decodes one message, returning nil when the peer closes.

read_timeout=(span : Time::Span | Nil) : Nil

Bounds how long read_message waits; nil blocks indefinitely.

socket

write_message(message : Message) : Nil

Encodes and writes one message without interleaving concurrent writers.