TheCloud/v
1
0
Fork 0
mirror of https://github.com/vlang/v.git synced 2025-09-10 07:47:20 -04:00
Code Issues Packages Projects Releases Wiki Activity

ci: fix ./v -W examples/eventbus/eventbus.v after 551a065 (todo: perhaps it should be reverted completely)

Browse Source
This commit is contained in:
Delyan Angelov 2023-09-19 07:24:50 +03:00
parent 77219de173
commit 350a8d3b35
No known key found for this signature in database
GPG Key ID: 66886C0F12D595ED
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
vlib/eventbus/eventbus.v
View File

@ -64,13 +64,15 @@ pub fn (eb &EventBus[T]) has_subscriber(name T) bool {
return eb.registry.check_subscriber(name) return eb.registry.check_subscriber(name)
} }
const dedup_buffer_len = 20
// publish publish an event with provided Params & name. // publish publish an event with provided Params & name.
fn (mut pb Publisher[T]) publish(name T, sender voidptr, args voidptr) { fn (mut pb Publisher[T]) publish(name T, sender voidptr, args voidptr) {
// println('Publisher.publish(name=${name} sender=${sender} args=${args})') // println('Publisher.publish(name=${name} sender=${sender} args=${args})')
mut handled_receivers := [20]voidptr{} // handle duplicate bugs TODO fix properly + perf mut handled_receivers := unsafe { [eventbus.dedup_buffer_len]voidptr{} } // handle duplicate bugs TODO fix properly + perf
// is_key_down := name == 'on_key_down' // is_key_down := name == 'on_key_down'
mut j := 0 mut j := 0
for i, event in pb.registry.events { for event in pb.registry.events {
if event.name == name { if event.name == name {
// if is_key_down { // if is_key_down {
if event.receiver in handled_receivers { if event.receiver in handled_receivers {
@ -81,7 +83,7 @@ fn (mut pb Publisher[T]) publish(name T, sender voidptr, args voidptr) {
event.handler(event.receiver, args, sender) event.handler(event.receiver, args, sender)
// handled_receivers << event.receiver // handled_receivers << event.receiver
handled_receivers[j] = event.receiver handled_receivers[j] = event.receiver
j++ j = (j + 1) % eventbus.dedup_buffer_len
} }
} }
pb.registry.events = pb.registry.events.filter(!(it.name == name && it.once)) pb.registry.events = pb.registry.events.filter(!(it.name == name && it.once))