code: func (s *Server) handleSnapshotConn(conn net.Conn) {
  	go func() {
  		defer conn.Close()
  		if err := s.handleSnapshotRequest(conn); err != nil {
  			s.logger.Printf("[ERR] consul.rpc: Snapshot RPC error: %v %s", err, logConn(conn))
  		}
  	}()
  }
docs: // handleSnapshotConn is used to dispatch snapshot saves and restores, which
  // stream so don't use the normal RPC mechanism.