1
0
mirror of https://github.com/vlang/v.git synced 2023-08-10 21:13:21 +03:00
v/vlib/eventbus/eventbus.v

124 lines
2.9 KiB
V
Raw Normal View History

2019-11-23 14:24:25 +03:00
module eventbus
pub type EventHandlerFn = fn (receiver voidptr, args voidptr, sender voidptr)
2020-01-22 19:41:08 +03:00
pub struct Publisher {
2020-01-22 19:41:08 +03:00
mut:
registry &Registry
}
2019-11-23 14:24:25 +03:00
pub struct Subscriber {
2020-01-22 19:41:08 +03:00
mut:
2019-11-23 14:24:25 +03:00
registry &Registry
}
2020-01-22 19:41:08 +03:00
struct Registry {
mut:
events []EventHandler
2019-11-23 14:24:25 +03:00
}
struct EventHandler {
name string
handler EventHandlerFn
receiver voidptr = voidptr(0)
once bool
2019-11-23 14:24:25 +03:00
}
2020-01-22 19:41:08 +03:00
pub struct EventBus {
pub mut:
registry &Registry
publisher &Publisher
subscriber &Subscriber
2019-11-23 14:24:25 +03:00
}
2020-01-22 19:41:08 +03:00
pub fn new() &EventBus {
2019-11-23 14:24:25 +03:00
registry := &Registry{
events: []
}
return &EventBus{registry, &Publisher{registry}, &Subscriber{registry}}
2019-11-23 14:24:25 +03:00
}
// EventBus Methods
2020-01-22 19:41:08 +03:00
pub fn (eb &EventBus) publish(name string, sender voidptr, args voidptr) {
mut publisher := eb.publisher
2020-01-22 19:41:08 +03:00
publisher.publish(name, sender, args)
}
2020-01-22 19:41:08 +03:00
pub fn (eb &EventBus) clear_all() {
mut publisher := eb.publisher
publisher.clear_all()
}
pub fn (eb &EventBus) has_subscriber(name string) bool {
return eb.registry.check_subscriber(name)
}
// Publisher Methods
2020-05-17 14:51:18 +03:00
fn (mut pb Publisher) publish(name string, sender voidptr, args voidptr) {
for event in pb.registry.events {
2020-01-22 19:41:08 +03:00
if event.name == name {
event.handler(event.receiver, args, sender)
2019-11-23 14:24:25 +03:00
}
}
pb.registry.events = pb.registry.events.filter(!(it.name == name && it.once))
2019-11-23 14:24:25 +03:00
}
2020-05-17 14:51:18 +03:00
fn (mut p Publisher) clear_all() {
p.registry.events.clear()
2019-11-23 14:24:25 +03:00
}
// Subscriber Methods
2020-05-17 14:51:18 +03:00
pub fn (mut s Subscriber) subscribe(name string, handler EventHandlerFn) {
s.registry.events << EventHandler{
2020-01-22 19:41:08 +03:00
name: name
handler: handler
}
}
2019-11-23 14:24:25 +03:00
2020-05-17 14:51:18 +03:00
pub fn (mut s Subscriber) subscribe_method(name string, handler EventHandlerFn, receiver voidptr) {
s.registry.events << EventHandler{
2020-01-22 19:41:08 +03:00
name: name
handler: handler
receiver: receiver
}
2019-11-23 14:24:25 +03:00
}
// unsubscribe_method unsubscribe a receiver for only one method
pub fn (mut s Subscriber) unsubscribe_method(name string, receiver voidptr) {
s.registry.events = s.registry.events.filter(!(it.name == name && it.receiver == receiver))
}
// unsubscribe_receiver unsubscribes a receiver from all events
pub fn (mut s Subscriber) unsubscribe_receiver(receiver voidptr) {
s.registry.events = s.registry.events.filter(it.receiver != receiver)
}
2020-05-17 14:51:18 +03:00
pub fn (mut s Subscriber) subscribe_once(name string, handler EventHandlerFn) {
s.registry.events << EventHandler{
2020-01-22 19:41:08 +03:00
name: name
handler: handler
once: true
}
2019-11-23 14:24:25 +03:00
}
pub fn (s &Subscriber) is_subscribed(name string) bool {
return s.registry.check_subscriber(name)
}
// is_subscribed_method checks whether a receiver was already subscribed for any events
pub fn (s &Subscriber) is_subscribed_method(name string, receiver voidptr) bool {
return s.registry.events.any(it.name == name && it.receiver == receiver)
}
2020-05-17 14:51:18 +03:00
pub fn (mut s Subscriber) unsubscribe(name string, handler EventHandlerFn) {
2020-01-22 19:41:08 +03:00
// v := voidptr(handler)
s.registry.events = s.registry.events.filter(!(it.name == name && it.handler == handler))
2019-11-23 14:24:25 +03:00
}
// Registry Methods
fn (r &Registry) check_subscriber(name string) bool {
return r.events.any(it.name == name)
2019-11-23 14:24:25 +03:00
}