blob: 7b051cbed3ddd32e332e88bad5f2cc5d0d945e59 (
plain) (
blame)
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
|
package gui
import (
"image"
"image/draw"
"sync"
)
type Mux struct {
mu sync.Mutex
eventsIns []chan<- Event
draw chan<- func(draw.Image) image.Rectangle
}
func NewMux(env Env) (mux *Mux, master Env) {
drawChan := make(chan func(draw.Image) image.Rectangle)
mux = &Mux{draw: drawChan}
master = mux.makeEnv(true)
go func() {
for d := range drawChan {
env.Draw() <- d
}
close(env.Draw())
}()
go func() {
for e := range env.Events() {
mux.mu.Lock()
for _, eventsIn := range mux.eventsIns {
eventsIn <- e
}
mux.mu.Unlock()
}
mux.mu.Lock()
for _, eventsIn := range mux.eventsIns {
close(eventsIn)
}
mux.mu.Unlock()
}()
return mux, master
}
func (mux *Mux) MakeEnv() Env {
return mux.makeEnv(false)
}
type muxEnv struct {
events <-chan Event
draw chan<- func(draw.Image) image.Rectangle
}
func (m *muxEnv) Events() <-chan Event { return m.events }
func (m *muxEnv) Draw() chan<- func(draw.Image) image.Rectangle { return m.draw }
func (mux *Mux) makeEnv(master bool) Env {
eventsOut, eventsIn := MakeEventsChan()
drawChan := make(chan func(draw.Image) image.Rectangle)
env := &muxEnv{eventsOut, drawChan}
mux.mu.Lock()
mux.eventsIns = append(mux.eventsIns, eventsIn)
mux.mu.Unlock()
go func() {
for d := range drawChan {
mux.draw <- d
}
if master {
mux.mu.Lock()
for _, eventsIn := range mux.eventsIns {
close(eventsIn)
}
mux.eventsIns = nil
close(mux.draw)
mux.mu.Unlock()
} else {
mux.mu.Lock()
i := -1
for i = range mux.eventsIns {
if mux.eventsIns[i] == eventsIn {
break
}
}
if i != -1 {
mux.eventsIns = append(mux.eventsIns[:i], mux.eventsIns[i+1:]...)
}
mux.mu.Unlock()
}
}()
return env
}
|