Commit 6e44dd4a by lancet

failsafe in control

parent 62c85978
...@@ -17,7 +17,10 @@ func (store *Store) control() { ...@@ -17,7 +17,10 @@ func (store *Store) control() {
break break
} }
} }
case request := <-store.exchange: case request, ok := <-store.exchange:
if !ok {
break
}
reply := Message{} reply := Message{}
switch request.Action { switch request.Action {
case "SET": case "SET":
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment