From 34dd27a1e9a41fd2a2df36ce940c0826385db25a Mon Sep 17 00:00:00 2001
From: overtake <overtakeful@gmail.com>
Date: Fri, 26 Feb 2021 17:06:46 +0400
Subject: [PATCH] - added complete handler for pre upload manager

---
 .../Sources/MessageMediaPreuploadManager.swift             | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/submodules/TelegramCore/Sources/MessageMediaPreuploadManager.swift b/submodules/TelegramCore/Sources/MessageMediaPreuploadManager.swift
index b60f898f27..e53e9b0414 100644
--- a/submodules/TelegramCore/Sources/MessageMediaPreuploadManager.swift
+++ b/submodules/TelegramCore/Sources/MessageMediaPreuploadManager.swift
@@ -33,7 +33,7 @@ private final class MessageMediaPreuploadManagerContext {
         assert(self.queue.isCurrent())
     }
     
-    func add(network: Network, postbox: Postbox, id: Int64, encrypt: Bool, tag: MediaResourceFetchTag?, source: Signal<MediaResourceData, NoError>) {
+    func add(network: Network, postbox: Postbox, id: Int64, encrypt: Bool, tag: MediaResourceFetchTag?, source: Signal<MediaResourceData, NoError>, onComplete:(()->Void)? = nil) {
         let context = MessageMediaPreuploadManagerUploadContext()
         self.uploadContexts[id] = context
         let queue = self.queue
@@ -47,6 +47,7 @@ private final class MessageMediaPreuploadManagerContext {
                         default:
                             print("result")
                             context.result = next
+                            onComplete?()
                     }
                     for subscriber in context.subscribers.copyItems() {
                         subscriber(next)
@@ -112,9 +113,9 @@ public final class MessageMediaPreuploadManager {
         })
     }
     
-    public func add(network: Network, postbox: Postbox, id: Int64, encrypt: Bool, tag: MediaResourceFetchTag?, source: Signal<MediaResourceData, NoError>) {
+    public func add(network: Network, postbox: Postbox, id: Int64, encrypt: Bool, tag: MediaResourceFetchTag?, source: Signal<MediaResourceData, NoError>, onComplete:(()->Void)? = nil) {
         self.impl.with { context in
-            context.add(network: network, postbox: postbox, id: id, encrypt: encrypt, tag: tag, source: source)
+            context.add(network: network, postbox: postbox, id: id, encrypt: encrypt, tag: tag, source: source, onComplete: onComplete)
         }
     }