forked from LBRYCommunity/lbry-sdk
fixes from review
This commit is contained in:
parent
ca4a55ef28
commit
f5bf1463af
2 changed files with 2 additions and 2 deletions
|
@ -96,7 +96,7 @@ class BlobFile:
|
||||||
raise error
|
raise error
|
||||||
return callback
|
return callback
|
||||||
|
|
||||||
async def save_verified_blob(self, writer, verified_bytes):
|
async def save_verified_blob(self, writer, verified_bytes: bytes):
|
||||||
def _save_verified():
|
def _save_verified():
|
||||||
# log.debug(f"write blob file {self.blob_hash[:8]} from {writer.peer.address}")
|
# log.debug(f"write blob file {self.blob_hash[:8]} from {writer.peer.address}")
|
||||||
if not self.saved_verified_blob and not os.path.isfile(self.file_path):
|
if not self.saved_verified_blob and not os.path.isfile(self.file_path):
|
||||||
|
|
|
@ -205,7 +205,7 @@ class StreamManager:
|
||||||
return stream
|
return stream
|
||||||
except asyncio.CancelledError:
|
except asyncio.CancelledError:
|
||||||
downloader.stop()
|
downloader.stop()
|
||||||
log.info("stopped stream")
|
log.debug("stopped stream")
|
||||||
|
|
||||||
async def download_stream_from_claim(self, node: 'Node', claim_info: typing.Dict,
|
async def download_stream_from_claim(self, node: 'Node', claim_info: typing.Dict,
|
||||||
file_name: typing.Optional[str] = None,
|
file_name: typing.Optional[str] = None,
|
||||||
|
|
Loading…
Add table
Reference in a new issue