code: func DialInProc(handler *Server) *Client {
  	initctx := context.Background()
  	c, _ := newClient(initctx, func(context.Context) (ServerCodec, error) {
  		p1, p2 := net.Pipe()
  		go handler.ServeCodec(NewJSONCodec(p1), OptionMethodInvocation|OptionSubscriptions)
  		return NewJSONCodec(p2), nil
  	})
  	return c
  }
docs: // DialInProc attaches an in-process connection to the given RPC server.