class Obsctl::IPC::ClientSession

• Obsctl::IPC::ClientSession
• Reference
• Object

Overview

Thread-safe message wrapper around one connected Unix socket.

Defined in:

obsctl/ipc/client_session.cr

Constructors

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

  Creates a session over an accepted or connected Unix socket.

Instance Method Summary

• #close : Nil

  Closes the underlying socket if it is still open.

• #read_message : Message | Nil

  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 : UNIXSocket
• #write_message(message : Message) : Nil

  Encodes and writes one message without interleaving concurrent writers.

Constructor Detail

Instance Method Detail