Method Serve

cli/rpcserve/jsonrpc.go:90–105

Serve reads and dispatches messages until ctx is canceled or in hits EOF.

(ctx context.Context)

// Serve reads and dispatches messages until ctx is canceled or in hits EOF.
func (s *Server) Serve(ctx context.Context) error {
	scanner := bufio.NewScanner(s.in)
	scanner.Buffer(make([]byte, 0, 64*1024), 8*1024*1024) // allow large payloads

	for scanner.Scan() {
		if ctx.Err() != nil {
			return ctx.Err()
		}
		line := scanner.Bytes()
		if len(line) == 0 {
			continue
		}
		s.dispatch(ctx, line)
	}
	return scanner.Err()
}

func (s *Server) dispatch(ctx context.Context, line []byte) {
	var req Request