Fixed foreign events.
This commit is contained in:
parent
a8da22272f
commit
b6bf7402ab
|
@ -146,8 +146,6 @@ func NewForeignEvent(channel interface{}, handler func(data interface{})) *Forei
|
||||||
}
|
}
|
||||||
|
|
||||||
func (fe *ForeignEvent) do() {
|
func (fe *ForeignEvent) do() {
|
||||||
wait := make(chan struct{})
|
|
||||||
defer close(wait)
|
|
||||||
for {
|
for {
|
||||||
v, ok := fe.c.Recv()
|
v, ok := fe.c.Recv()
|
||||||
if !ok {
|
if !ok {
|
||||||
|
@ -156,9 +154,7 @@ func (fe *ForeignEvent) do() {
|
||||||
fe.d = v.Interface()
|
fe.d = v.Interface()
|
||||||
Do(func() {
|
Do(func() {
|
||||||
fe.e.fire()
|
fe.e.fire()
|
||||||
wait <- struct{}{}
|
|
||||||
})
|
})
|
||||||
<-wait
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue