bzrlib.remote.RemoteStreamSink : API documentation

Method	insert_stream	Insert a stream's content into the target repository.
Method	_insert_real	Undocumented
Method	_resume_stream_with_vfs	Resume sending a stream via VFS, first resending the record and
Method	_stop_stream_if_inventory_delta	Normally this just lets the original stream pass-through unchanged.

Inherited from StreamSink:

Method	__init__	Undocumented
Method	insert_stream_without_locking	Insert a stream's content into the target repository.
Method	finished	Undocumented
Method	_extract_and_insert_inventory_deltas	Undocumented
Method	_extract_and_insert_inventories	Generate a new inventory versionedfile in target, converting data.
Method	_extract_and_insert_revisions	Undocumented

def insert_stream(self, stream, src_format, resume_tokens):

overrides bzrlib.vf_repository.StreamSink.insert_stream

Insert a stream's content into the target repository.

Parameters	src_format	a bzr repository format.
Returns	a list of resume tokens and an iterable of keys additional items required before the insertion can be completed.

def _resume_stream_with_vfs(self, response, src_format):

Resume sending a stream via VFS, first resending the record and substream that couldn't be sent via an insert_stream verb.

def _stop_stream_if_inventory_delta(self, stream):

Normally this just lets the original stream pass-through unchanged.

However if any 'inventory-deltas' substream occurs it will stop streaming, and store the interrupted substream and stream in self._last_substream and self._last_stream so that the stream can be resumed by _resume_stream_with_vfs.

b.r.RemoteStreamSink(vf_repository.StreamSink) : class documentation