pub struct EventBus[T] {
mut:
    subscribers map[string][]Subscriber[T]
}

type EventType = string
type Subscriber[T] = fn (T)

pub fn new_event_bus[T]() &EventBus[T] {
    return &EventBus[T]{
        subscribers: map[string][]Subscriber[T]{}
    }
}

fn (shared eb EventBus[T]) subscribe(event_type EventType, subscriber Subscriber[T]) {
    lock eb {
        if event_type !in eb.subscribers {
            eb.subscribers[event_type] = []Subscriber[T]{}
        }

        eb.subscribers[event_type] << subscriber
    }
}

fn (shared eb EventBus[T]) publish(event_type EventType, data T) {
    lock eb {
        for _, subscriber in eb.subscribers[event_type] {
            subscriber(data)
        }
    }
}

fn main() {
    shared eb_string := new_event_bus[string]()
    eb_string.subscribe('test', fn (data string) {
        println(data)
    })
    eb_string.publish('test', 'hello')

    shared eb_int := new_event_bus[int]()
    eb_int.subscribe('test', fn (data int) {
        println(data)
    })
    eb_int.publish('test', 22)
}