SocketEventBridge

​

Constructor params

• path: unix socket path (absolute path recommended)
• name: optional bridge label

from bubus import SocketEventBridge

bridge = SocketEventBridge('/tmp/bubus_events.sock', name='SocketBridge')

import { SocketEventBridge } from 'bubus'

const bridge = new SocketEventBridge('/tmp/bubus_events.sock', 'SocketBridge')

​

Setup with a bus

from bubus import EventBus, SocketEventBridge

bus = EventBus('AppBus')
bridge = SocketEventBridge('/tmp/bubus_events.sock')

bus.on('*', bridge.emit)
bridge.on('*', bus.emit)

import { EventBus, SocketEventBridge } from 'bubus'

const bus = new EventBus('AppBus')
const bridge = new SocketEventBridge('/tmp/bubus_events.sock')

bus.on('*', bridge.emit)
bridge.on('*', bus.emit)

​

Behavior

• emit(...) writes newline-delimited event JSON frames to the unix socket.
• on(...) subscribes handlers on the inbound side and auto-starts the socket listener.
• Incoming frames are decoded into events, reset, then emitted on the internal bus.
• close() stops the socket server and tears down the internal bus.
• TypeScript socket bridges require Node.js runtime support for unix sockets.