Fix: early stopped engine (#105)

This commit is contained in:
xjasonlyu
2022-03-29 13:39:18 +08:00
parent 584c9c7805
commit 376a1eac2c
+4 -4
View File
@@ -58,14 +58,14 @@ func main() {
engine.Insert(key)
assert := func(msg string, err error) {
if err != nil {
assert := func(msg string, f func() error) {
if err := f(); err != nil {
log.Fatalf("Failed to %s: %v", msg, err)
}
}
assert("start engine", engine.Start())
defer assert("stop engine", engine.Stop())
assert("start engine", engine.Start)
defer assert("stop engine", engine.Stop)
sigCh := make(chan os.Signal, 1)
signal.Notify(sigCh, syscall.SIGINT, syscall.SIGTERM)