commit
8425ae77f8
@ -42,6 +42,8 @@ func (t *table) sendEvent(e *Event) {
|
|||||||
select {
|
select {
|
||||||
case w.resChan <- e:
|
case w.resChan <- e:
|
||||||
case <-w.done:
|
case <-w.done:
|
||||||
|
// don't block forever
|
||||||
|
case <-time.After(time.Second):
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user