> ## 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.
# Overview
> Unified docs for abxbus Python, TypeScript, Rust, and Go implementations.
## `abxbus`: Production-ready multi-language event bus
[](https://deepwiki.com/ArchiveBox/abxbus) [](https://pypi.org/project/abxbus/) [](https://www.npmjs.com/package/abxbus) [](https://github.com/ArchiveBox/abxbus)
AbxBus is an in-memory event bus for async Python, TypeScript (Node and browser environments), Rust, and Go, built for predictable event-driven workflows with strong typing and consistent cross-language behavior.
Core strengths:
* 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
```python theme={null}
from abxbus 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)).now()
```
```ts theme={null}
import { BaseEvent, EventBus } from "abxbus";
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 })).now();
```
```rust theme={null}
use abxbus::{event, event_bus::EventBus};
use futures::executor::block_on;
event! {
struct SomeEvent {
some_data: i64,
event_result_type: String,
}
}
let bus = EventBus::new(Some("MyBus".to_string()));
bus.on(SomeEvent, |event: SomeEvent| async move {
Ok(format!("did something with {}", event.some_data))
});
let event = bus.emit(SomeEvent { some_data: 132, ..Default::default() });
block_on(event.now())?;
```
```go theme={null}
package main
import (
"fmt"
abxbus "github.com/ArchiveBox/abxbus/abxbus-go"
)
func main() {
type SomeEvent struct {
SomeData int `json:"some_data"`
}
bus := abxbus.NewEventBus("MyBus", nil)
bus.On(func(event SomeEvent) {
fmt.Println(event.SomeData)
})
event := bus.Emit(SomeEvent{SomeData: 132})
_, _ = event.Now()
}
```
See [Quickstart](./quickstart) for installation and first full example.
## Repository examples
Runnable end-to-end examples and implementation smoke tests live in the repo:
* Quickstart basics:
* [`examples/simple.py`](https://github.com/ArchiveBox/abxbus/blob/main/examples/simple.py)
* [`abxbus-ts/examples/simple.ts`](https://github.com/ArchiveBox/abxbus/blob/main/abxbus-ts/examples/simple.ts)
* Concurrency modes, overrides, and timeout behavior:
* [`examples/concurrency_options.py`](https://github.com/ArchiveBox/abxbus/blob/main/examples/concurrency_options.py)
* [`abxbus-ts/examples/concurrency_options.ts`](https://github.com/ArchiveBox/abxbus/blob/main/abxbus-ts/examples/concurrency_options.ts)
* Immediate execution (queue-jump) behavior:
* [`examples/immediate_event_processing.py`](https://github.com/ArchiveBox/abxbus/blob/main/examples/immediate_event_processing.py)
* [`abxbus-ts/examples/immediate_event_processing.ts`](https://github.com/ArchiveBox/abxbus/blob/main/abxbus-ts/examples/immediate_event_processing.ts)
* Forwarding between buses:
* [`examples/forwarding_between_busses.py`](https://github.com/ArchiveBox/abxbus/blob/main/examples/forwarding_between_busses.py)
* [`abxbus-ts/examples/forwarding_between_busses.ts`](https://github.com/ArchiveBox/abxbus/blob/main/abxbus-ts/examples/forwarding_between_busses.ts)
* Parent-child lineage tracking:
* [`examples/parent_child_tracking.py`](https://github.com/ArchiveBox/abxbus/blob/main/examples/parent_child_tracking.py)
* [`abxbus-ts/examples/parent_child_tracking.ts`](https://github.com/ArchiveBox/abxbus/blob/main/abxbus-ts/examples/parent_child_tracking.ts)
* Tree logs with nested timeout outcomes:
* [`examples/log_tree_demo.py`](https://github.com/ArchiveBox/abxbus/blob/main/examples/log_tree_demo.py)
* [`abxbus-ts/examples/log_tree_demo.ts`](https://github.com/ArchiveBox/abxbus/blob/main/abxbus-ts/examples/log_tree_demo.ts)
* Rust parity and roundtrip tests:
* [`abxbus-rust/tests/test_comprehensive_patterns.rs`](https://github.com/ArchiveBox/abxbus/blob/main/abxbus-rust/tests/test_comprehensive_patterns.rs)
* [`abxbus-rust/tests/test_cross_runtime_roundtrip.rs`](https://github.com/ArchiveBox/abxbus/blob/main/abxbus-rust/tests/test_cross_runtime_roundtrip.rs)
* Go parity and roundtrip helper:
* [`abxbus-go/tests/comprehensive_patterns_test.go`](https://github.com/ArchiveBox/abxbus/blob/main/abxbus-go/tests/comprehensive_patterns_test.go)
* [`abxbus-go/tests/roundtrip_cli`](https://github.com/ArchiveBox/abxbus/blob/main/abxbus-go/tests/roundtrip_cli/main.go)