Fixes unclosed chan

dedis · Mar 23, 2021 · a4a6c63 · a4a6c63
1 parent 44bcfec
commit a4a6c63
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/processor.go b/processor.go
@@ -480,15 +480,19 @@ func (p *ServiceProcessor) ProcessClientStreamRequest(req *http.Request, path st
 				network.DefaultConstructors(p.Context.server.Suite()))
 			if err != nil {
 				log.Error(xerrors.Errorf("failed to decode message: %v", err))
+				close(outChan)
 				return
 			}
 
 			reply, stopServiceChan, err := callInterfaceFunc(mh.handler, msg, mh.streaming)
 			if err != nil {
 				log.Error(err)
+
 				if stopServiceChan != nil {
 					close(stopServiceChan)
 				}
+
+				close(outChan)
 				return
 			}