emit(...)for outbound forwardingon(...)for inbound subscriptionstart()andclose()for lifecycle control
Quick setup
- Python
- TypeScript
Transport bridges for forwarding events across files, sockets, and external services.
emit(...) for outbound forwardingon(...) for inbound subscriptionstart() and close() for lifecycle controlfrom bubus import EventBus, RedisEventBridge
bus = EventBus('AppBus')
bridge = RedisEventBridge('redis://localhost:6379/0/bubus_events')
bus.on('*', bridge.emit)
bridge.on('*', bus.emit)
import { EventBus, RedisEventBridge } from 'bubus'
const bus = new EventBus('AppBus')
const bridge = new RedisEventBridge('redis://localhost:6379/0/bubus_events')
bus.on('*', bridge.emit)
bridge.on('*', bus.emit)