event: guarantee the order on which events are delivered

Now instead of guaranteeing that the message will be eventually delivered (even if channels are full), we guarantee that they will be delivered in order, as long as the listener channels aren't full.
chenguang209 · Jul 26, 2017 · 6854512 · 6854512
1 parent 78dd980
commit 6854512
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/event.go b/event.go
@@ -216,7 +216,7 @@ func (eventState *eventMonitoringState) monitorEvents(c *Client) {
 				return
 			}
 			eventState.updateLastSeen(ev)
-			go eventState.sendEvent(ev)
+			eventState.sendEvent(ev)
 		case err = <-eventState.errC:
 			if err == ErrNoListeners {
 				eventState.disableEventMonitoring()
@@ -274,7 +274,10 @@ func (eventState *eventMonitoringState) sendEvent(event *APIEvents) {
 		}
 
 		for _, listener := range eventState.listeners {
-			listener <- event
+			select {
+			case listener <- event:
+			default:
+			}
 		}
 	}
 }