lib9p

commit c140dfd37336705a9b79a4e75ceaf9380a8ce6dd
parent 4bf49d56a1811d781e8405737992c5d9af173da5
Author: Matsuda Kenji <info@mtkn.jp>
Date:   Mon, 25 Dec 2023 09:25:26 +0900

change getReq signature

Diffstat:
M
server.go
 | 
6
+++---

1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/server.go b/server.go
@@ -119,7 +119,7 @@ func (s *Server) runListener(ctx context.Context) {
 		defer close(rc)
 		for {
 			select {
-			case rc <- getReq(s.r, s):
+			case rc <- s.getReq():
 			case <-ctx.Done():
 				return
 			}
@@ -157,8 +157,8 @@ func (s *Server) runSpeaker(ctx context.Context) {
 // Any error it encounters is embedded into the Req struct.
 // This function is called only by the server's listener goroutine,
 // and does not need to lock r.
-func getReq(r io.Reader, s *Server) *Req {
-	ifcall, err := RecvMsg(r)
+func (s *Server)getReq() *Req {
+	ifcall, err := RecvMsg(s.r)
 	if err != nil {
 		if err == io.EOF {
 			return &Req{listenErr: err}