JSONLEventBridge

Documentation Index

Fetch the complete documentation index at: https://abxbus.archivebox.io/llms.txt

Use this file to discover all available pages before exploring further.

​

Constructor params

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

from abxbus.bridges import JSONLEventBridge

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

import { JSONLEventBridge } from 'abxbus/bridges'

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

​

Setup with a bus

from abxbus import EventBus
from abxbus.bridges import JSONLEventBridge

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

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

import { EventBus } from 'abxbus'
import { JSONLEventBridge } from 'abxbus/bridges'

const bus = new EventBus('AppBus')
const bridge = new JSONLEventBridge('/tmp/abxbus_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.