Elara6331/lrpc
Archived
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add (*Server).HandleConn()

Browse Source
This commit is contained in:
Elara 2022-05-16 15:42:15 -07:00
parent bc7aa0fe5b
commit fbae725040
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
server/server.go
View File

@ -278,7 +278,14 @@ func (s *Server) ServeWS(ctx context.Context, addr string, cf codec.CodecFunc) (
return server.ListenAndServe() return server.ListenAndServe()
} }
// handleConn handles a listener connection // ServeConn uses the provided connection to serve the client.
// This may be useful if something other than a net.Listener
// needs to be used
func (s *Server) ServeConn(ctx context.Context, conn io.ReadWriter, cf codec.CodecFunc) {
s.handleConn(ctx, cf(conn))
}
// handleConn handles a connection
func (s *Server) handleConn(pCtx context.Context, c codec.Codec) { func (s *Server) handleConn(pCtx context.Context, c codec.Codec) {
codecMtx := &sync.Mutex{} codecMtx := &sync.Mutex{}