Merge pull request #11 from findcoo/dev-0

AtCancel at received sigterm
findcoo · Aug 22, 2017 · 7bb8123 · 7bb8123
2 parents a544c64 + ce9d5e6
commit 7bb8123
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/observer.go b/observer.go
@@ -83,6 +83,7 @@ func (o *Observer) Watch(target func()) {
 			select {
 			case state := <-sig:
 				log.Printf("capture signal: %s: end observ", state)
+				o.Handler.AtCancel()
 				o.endSubscribe()
 				return
 			case <-o.doneObserv: