add panic() to chanRe.SetError if Emit fails

061fe813 · keks · 3486c987 · 061fe813
Commit 061fe813 authored Oct 11, 2017 by keks
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 1 deletion

chan.go chan.go +4 -1

No files found.
--- a/chan.go
+++ b/chan.go
@@ -113,7 +113,10 @@ type chanResponseEmitter struct {
 }
 func (re *chanResponseEmitter) SetError(v interface{}, errType cmdkit.ErrorType) {
-	re.Emit(&cmdkit.Error{Message: fmt.Sprint(v), Code: errType})
+	err := re.Emit(&cmdkit.Error{Message: fmt.Sprint(v), Code: errType})
+	if err != nil {
+		panic(err)
+	}
 }
 func (re *chanResponseEmitter) SetLength(l uint64) {