Overview

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();

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())?;

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()
}