diff --git a/subscription.go b/subscription.go
index 381de5d..12026b8 100644
--- a/subscription.go
+++ b/subscription.go
@@ -70,7 +70,10 @@ func (sub *Subscription) start() {
 			go func() {
 				mu.Lock()
 				if sub.live.Load() {
-					sub.Events <- event
+					select {
+					case sub.Events <- event:
+					case <-sub.Context.Done():
+					}
 				}
 				mu.Unlock()
 			}()