JSONLEventBridge

​

Constructor params

• path: JSONL file path
• poll_interval: tail polling interval in seconds (default 0.25)
• name: optional bridge label

from bubus import JSONLEventBridge

bridge = JSONLEventBridge(
    '/tmp/bubus_events.jsonl',
    poll_interval=0.25,
    name='JsonlBridge',
)

import { JSONLEventBridge } from 'bubus'

const bridge = new JSONLEventBridge('/tmp/bubus_events.jsonl', 0.25, 'JsonlBridge')

​

Setup with a bus

from bubus import EventBus, JSONLEventBridge

bus = EventBus('AppBus')
bridge = JSONLEventBridge('/tmp/bubus_events.jsonl')

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

import { EventBus, JSONLEventBridge } from 'bubus'

const bus = new EventBus('AppBus')
const bridge = new JSONLEventBridge('/tmp/bubus_events.jsonl')

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

​

Behavior

• emit(...) appends compact JSON payload + newline to the file.
• on(...) auto-starts a tail loop and registers inbound handlers.
• Start cursor is initialized at current EOF, so only newly appended lines are processed.
• Malformed lines are ignored; valid lines are parsed into events, reset, and emitted on the internal bus.
• Runtime note: TypeScript JSONL bridge is Node.js-only.