Class●Since v0.0

UnixSocketEventSource

UnixSocketEventSource(
    self,
    path: Path | None = None,
)

Constructors

Attributes

Methods

View source on GitHub

Parameters

Name	Type	Description
`path`	`Path \| None`	Default:`None` Socket path. When omitted, a per-process path under the runtime or temp directory is used.

constructor

__init__

Name	Type
path	Path \| None

Start listening for newline-delimited JSON events.

method

serve_forever

Park until the underlying server is cancelled or fails.

asyncio.start_unix_server already begins accepting connections, so this delegates to the server's own serve_forever. A fatal error inside the accept loop propagates here, letting the lifecycle owner notice and react.

method

stop

Close the listener and remove the socket path.

Idempotent: safe to call after a failed or never-started start().

Line-delimited JSON event source over a local Unix domain socket.

The listener creates its parent directory with mode 0o700 and binds the socket inside it under a transient umask(0o077) so the socket inherits 0o600 from the moment of bind(). Stale sockets at the configured path are removed on start, but only after a stat confirms the path is a socket — a regular file or directory at that path is left untouched and causes start to fail loudly.

LangChain Assistant

Menu

UnixSocketEventSource

Constructors

Attributes

Methods

Parameters