681 

   681 

   682 def _walkstreamfiles(repo):

   682 def _walkstreamfiles(repo):

   683     # this is it's own function so extensions can override it

   683     # this is it's own function so extensions can override it

   684     return repo.store.walk()

   684     return repo.store.walk()

   685 

   685 

   686 def stream(repo, proto):

   687 def stream(repo, proto):

   687     '''If the server supports streaming clone, it advertises the "stream"

   688     '''If the server supports streaming clone, it advertises the "stream"

   688     capability with a value representing the version and flags of the repo

   689     capability with a value representing the version and flags of the repo

   689     it is serving. Client checks to see if it understands the format.

   690     it is serving. Client checks to see if it understands the format.

   690 

   691 

   794     finally:

   795     finally:

   795         fp.close()

   796         fp.close()

   796         os.unlink(tempname)

   797         os.unlink(tempname)

   797 

   798 

   798 commands.update({

   799 commands.update({

   800     'unbundle': (unbundle, 'heads'),

   800     'unbundle': (unbundle, 'heads'),

   801 })

   801 })