don't block forever

2020-01-17 15:23:10 +00:00 · 2020-01-17 15:23:10 +00:00 · d7b9b2713b
commit d7b9b2713b
parent be788415ad
1 changed files with 2 additions and 0 deletions
--- a/router/table.go
+++ b/router/table.go
@ -42,6 +42,8 @@ func (t *table) sendEvent(e *Event) {
 		select {
 		case w.resChan <- e:
 		case <-w.done:
+		// don't block forever
+		case <-time.After(time.Second):
 		}
 	}
 }