-
Notifications
You must be signed in to change notification settings - Fork 8
/
Copy pathevent.go
118 lines (90 loc) · 2.12 KB
/
event.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
// Copyright 2011 The Walk Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
//go:build windows
// +build windows
package walk
type eventHandlerInfo struct {
handler EventHandler
once bool
}
type EventHandler func()
type Event struct {
handlers []eventHandlerInfo
}
func (e *Event) Attach(handler EventHandler) int {
handlerInfo := eventHandlerInfo{handler, false}
for i, h := range e.handlers {
if h.handler == nil {
e.handlers[i] = handlerInfo
return i
}
}
e.handlers = append(e.handlers, handlerInfo)
return len(e.handlers) - 1
}
func (e *Event) Detach(handle int) {
e.handlers[handle].handler = nil
}
func (e *Event) Once(handler EventHandler) {
i := e.Attach(handler)
e.handlers[i].once = true
}
type EventPublisher struct {
event Event
}
func (p *EventPublisher) Event() *Event {
return &p.event
}
func (p *EventPublisher) Publish() {
for i, h := range p.event.handlers {
if h.handler != nil {
h.handler()
if h.once {
p.event.Detach(i)
}
}
}
}
type genericEventHandlerInfo[T any] struct {
handler GenericEventHandler[T]
once bool
}
type GenericEventHandler[T any] func(param T)
type GenericEvent[T any] struct {
handlers []genericEventHandlerInfo[T]
}
func (e *GenericEvent[T]) Attach(handler GenericEventHandler[T]) int {
handlerInfo := genericEventHandlerInfo[T]{handler, false}
for i, h := range e.handlers {
if h.handler == nil {
e.handlers[i] = handlerInfo
return i
}
}
e.handlers = append(e.handlers, handlerInfo)
return len(e.handlers) - 1
}
func (e *GenericEvent[T]) Detach(handle int) {
e.handlers[handle].handler = nil
}
func (e *GenericEvent[T]) Once(handler GenericEventHandler[T]) {
i := e.Attach(handler)
e.handlers[i].once = true
}
type GenericEventPublisher[T any] struct {
event GenericEvent[T]
}
func (p *GenericEventPublisher[T]) Event() *GenericEvent[T] {
return &p.event
}
func (p *GenericEventPublisher[T]) Publish(param T) {
for i, h := range p.event.handlers {
if h.handler != nil {
h.handler(param)
if h.once {
p.event.Detach(i)
}
}
}
}