Maybe fix encrypted parallel file transfer

This commit is contained in:
Tulir Asokan
2020-08-18 20:27:40 +03:00
parent 1b2024e456
commit 953ef0e5bc
@@ -262,8 +262,8 @@ async def parallel_transfer_to_matrix(client: MautrixTelegramClient, intent: Int
async def encrypted(stream): async def encrypted(stream):
nonlocal decryption_info nonlocal decryption_info
async for chunk in async_encrypt_attachment(stream): async for chunk in async_encrypt_attachment(stream):
if isinstance(chunk, dict): if isinstance(chunk, EncryptedFile):
decryption_info = EncryptedFile.deserialize(chunk) decryption_info = chunk
else: else:
yield chunk yield chunk