Overview

​

bubus: Production-ready multi-language event bus

• Typed event payloads and typed handler return values
• Deterministic queue semantics with configurable concurrency
• Nested event lineage tracking (event_parent_id / event_path)
• Event forwarding, bridge transports, and middleware integration

​

Minimal usage

from bubus import BaseEvent, EventBus

class SomeEvent(BaseEvent):
    some_data: int

async def on_some_event(event: SomeEvent) -> None:
    print(event.some_data)
    # 132

bus = EventBus('MyBus')
bus.on(SomeEvent, on_some_event)

await bus.emit(SomeEvent(some_data=132))

import { BaseEvent, EventBus } from 'bubus'
import { z } from 'zod'

const SomeEvent = BaseEvent.extend('SomeEvent', {
  some_data: z.number(),
})

const bus = new EventBus('MyBus')
bus.on(SomeEvent, async (event) => {
  console.log(event.some_data)
})

await bus.emit(SomeEvent({ some_data: 132 })).done()

​

Repository examples

• Quickstart basics:
  • examples/simple.py
  • bubus-ts/examples/simple.ts
• Concurrency modes, overrides, and timeout behavior:
  • examples/concurrency_options.py
  • bubus-ts/examples/concurrency_options.ts
• Immediate execution (queue-jump) behavior:
  • examples/immediate_event_processing.py
  • bubus-ts/examples/immediate_event_processing.ts
• Forwarding between buses:
  • examples/forwarding_between_busses.py
  • bubus-ts/examples/forwarding_between_busses.ts
• Parent-child lineage tracking:
  • examples/parent_child_tracking.py
  • bubus-ts/examples/parent_child_tracking.ts
• Tree logs with nested timeout outcomes:
  • examples/log_tree_demo.py
  • bubus-ts/examples/log_tree_demo.ts