lib9p

commit 03cb14522b08ca8fec155c9c833fc0e1deafdc34
parent 176cca869c6bed56075961cdef68e62591668375
Author: Matsuda Kenji <info@mtkn.jp>
Date:   Sun,  8 Oct 2023 04:22:08 +0900

close channels

Diffstat:
M
server.go
 | 
4
++++

1 file changed, 4 insertions(+), 0 deletions(-)
diff --git a/server.go b/server.go
@@ -73,6 +73,8 @@ func (s *Server) runListener(r io.Reader) (<-chan *Req, <-chan error) {
 	rc := make(chan *Req)
 	ec := make(chan error)
 	go func() {
+		defer close(rc)
+		defer close(ec)
 		for {
 			req, err := getReq(r, s)
 			if err != nil {
@@ -88,6 +90,8 @@ func (s *Server) runSpeaker(w io.Writer) (chan<- *Req, <-chan error) {
 	rc := make(chan *Req, 3) // TODO: buffer size?
 	ec := make(chan error)
 	go func() {
+		defer close(rc)
+		defer close(ec)
 		for {
 			r := <-rc
 			_, err := w.Write(r.ofcall.marshal())