v/examples/eventbus/modules/some_module/some_module.v

module some_module

import eventbus

const (
	eb = eventbus.new()
)

pub struct Work {
pub:
	hours int
}

pub struct MyError {
pub:
	message string
}

pub fn do_work() {
	work := Work{20}
	for i in 0 .. 20 {
		println('working...')
		if i == 15 {
			error := &MyError{'There was an error.'}
			some_module.eb.publish('error', work, error)
			some_module.eb.publish('error', work, error)
			return
		}
	}
}

pub fn get_subscriber() eventbus.Subscriber {
	return *some_module.eb.subscriber
}