diff --git a/example/subscription/main.go b/example/subscription/main.go
index 06b467c62da3be3207f4745568a6d4eca0dc6b39..328af27dfe6f8c3d982e187ebf700b542611fa72 100644
--- a/example/subscription/main.go
+++ b/example/subscription/main.go
@@ -41,7 +41,9 @@ func main() {
 				for {
 					select {
 					case <-r.Context().Done():
+						return
 					case <-notifier.Err():
+						return
 					default:
 					}
 					notifier.Notify(idx)