diff --git a/pyrogram/client/methods/messages/send_animation.py b/pyrogram/client/methods/messages/send_animation.py
index 08b69c17..5b27c914 100644
--- a/pyrogram/client/methods/messages/send_animation.py
+++ b/pyrogram/client/methods/messages/send_animation.py
@@ -45,7 +45,7 @@ class SendAnimation(BaseClient):
                                            "pyrogram.ReplyKeyboardRemove",
                                            "pyrogram.ForceReply"] = None,
                        progress: callable = None,
-                       progress_args: tuple = ()) -> "pyrogram.Message":
+                       progress_args: tuple = ()) -> Union["pyrogram.Message", None]:
         """Use this method to send animation files (animation or H.264/MPEG-4 AVC video without sound).
 
         Args:
@@ -119,6 +119,7 @@ class SendAnimation(BaseClient):
 
         Returns:
             On success, the sent :obj:`Message <pyrogram.Message>` is returned.
+            In case the upload is deliberately stopped with :meth:`stop_transmission`, None is returned instead.
 
         Raises:
             :class:`Error <pyrogram.Error>` in case of a Telegram RPC error.
@@ -126,72 +127,75 @@ class SendAnimation(BaseClient):
         file = None
         style = self.html if parse_mode.lower() == "html" else self.markdown
 
-        if os.path.exists(animation):
-            thumb = None if thumb is None else self.save_file(thumb)
-            file = self.save_file(animation, progress=progress, progress_args=progress_args)
-            media = types.InputMediaUploadedDocument(
-                mime_type=mimetypes.types_map[".mp4"],
-                file=file,
-                thumb=thumb,
-                attributes=[
-                    types.DocumentAttributeVideo(
-                        supports_streaming=True,
-                        duration=duration,
-                        w=width,
-                        h=height
-                    ),
-                    types.DocumentAttributeFilename(os.path.basename(animation)),
-                    types.DocumentAttributeAnimated()
-                ]
-            )
-        elif animation.startswith("http"):
-            media = types.InputMediaDocumentExternal(
-                url=animation
-            )
-        else:
-            try:
-                decoded = utils.decode(animation)
-                fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
-                unpacked = struct.unpack(fmt, decoded)
-            except (AssertionError, binascii.Error, struct.error):
-                raise FileIdInvalid from None
-            else:
-                if unpacked[0] != 10:
-                    media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
-
-                    if media_type:
-                        raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
-                    else:
-                        raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
-
-                media = types.InputMediaDocument(
-                    id=types.InputDocument(
-                        id=unpacked[2],
-                        access_hash=unpacked[3],
-                        file_reference=b""
-                    )
+        try:
+            if os.path.exists(animation):
+                thumb = None if thumb is None else self.save_file(thumb)
+                file = self.save_file(animation, progress=progress, progress_args=progress_args)
+                media = types.InputMediaUploadedDocument(
+                    mime_type=mimetypes.types_map[".mp4"],
+                    file=file,
+                    thumb=thumb,
+                    attributes=[
+                        types.DocumentAttributeVideo(
+                            supports_streaming=True,
+                            duration=duration,
+                            w=width,
+                            h=height
+                        ),
+                        types.DocumentAttributeFilename(os.path.basename(animation)),
+                        types.DocumentAttributeAnimated()
+                    ]
                 )
-
-        while True:
-            try:
-                r = self.send(
-                    functions.messages.SendMedia(
-                        peer=self.resolve_peer(chat_id),
-                        media=media,
-                        silent=disable_notification or None,
-                        reply_to_msg_id=reply_to_message_id,
-                        random_id=self.rnd_id(),
-                        reply_markup=reply_markup.write() if reply_markup else None,
-                        **style.parse(caption)
-                    )
+            elif animation.startswith("http"):
+                media = types.InputMediaDocumentExternal(
+                    url=animation
                 )
-            except FilePartMissing as e:
-                self.save_file(animation, file_id=file.id, file_part=e.x)
             else:
-                for i in r.updates:
-                    if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
-                        return pyrogram.Message._parse(
-                            self, i.message,
-                            {i.id: i for i in r.users},
-                            {i.id: i for i in r.chats}
+                try:
+                    decoded = utils.decode(animation)
+                    fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
+                    unpacked = struct.unpack(fmt, decoded)
+                except (AssertionError, binascii.Error, struct.error):
+                    raise FileIdInvalid from None
+                else:
+                    if unpacked[0] != 10:
+                        media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
+
+                        if media_type:
+                            raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
+                        else:
+                            raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
+
+                    media = types.InputMediaDocument(
+                        id=types.InputDocument(
+                            id=unpacked[2],
+                            access_hash=unpacked[3],
+                            file_reference=b""
                         )
+                    )
+
+            while True:
+                try:
+                    r = self.send(
+                        functions.messages.SendMedia(
+                            peer=self.resolve_peer(chat_id),
+                            media=media,
+                            silent=disable_notification or None,
+                            reply_to_msg_id=reply_to_message_id,
+                            random_id=self.rnd_id(),
+                            reply_markup=reply_markup.write() if reply_markup else None,
+                            **style.parse(caption)
+                        )
+                    )
+                except FilePartMissing as e:
+                    self.save_file(animation, file_id=file.id, file_part=e.x)
+                else:
+                    for i in r.updates:
+                        if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
+                            return pyrogram.Message._parse(
+                                self, i.message,
+                                {i.id: i for i in r.users},
+                                {i.id: i for i in r.chats}
+                            )
+        except BaseClient.StopTransmission:
+            return None
diff --git a/pyrogram/client/methods/messages/send_audio.py b/pyrogram/client/methods/messages/send_audio.py
index da08f5f7..baa31a71 100644
--- a/pyrogram/client/methods/messages/send_audio.py
+++ b/pyrogram/client/methods/messages/send_audio.py
@@ -45,7 +45,7 @@ class SendAudio(BaseClient):
                                        "pyrogram.ReplyKeyboardRemove",
                                        "pyrogram.ForceReply"] = None,
                    progress: callable = None,
-                   progress_args: tuple = ()) -> "pyrogram.Message":
+                   progress_args: tuple = ()) -> Union["pyrogram.Message", None]:
         """Use this method to send audio files.
 
         For sending voice messages, use the :obj:`send_voice()` method instead.
@@ -121,6 +121,7 @@ class SendAudio(BaseClient):
 
         Returns:
             On success, the sent :obj:`Message <pyrogram.Message>` is returned.
+            In case the upload is deliberately stopped with :meth:`stop_transmission`, None is returned instead.
 
         Raises:
             :class:`Error <pyrogram.Error>` in case of a Telegram RPC error.
@@ -128,70 +129,73 @@ class SendAudio(BaseClient):
         file = None
         style = self.html if parse_mode.lower() == "html" else self.markdown
 
-        if os.path.exists(audio):
-            thumb = None if thumb is None else self.save_file(thumb)
-            file = self.save_file(audio, progress=progress, progress_args=progress_args)
-            media = types.InputMediaUploadedDocument(
-                mime_type=mimetypes.types_map.get("." + audio.split(".")[-1], "audio/mpeg"),
-                file=file,
-                thumb=thumb,
-                attributes=[
-                    types.DocumentAttributeAudio(
-                        duration=duration,
-                        performer=performer,
-                        title=title
-                    ),
-                    types.DocumentAttributeFilename(os.path.basename(audio))
-                ]
-            )
-        elif audio.startswith("http"):
-            media = types.InputMediaDocumentExternal(
-                url=audio
-            )
-        else:
-            try:
-                decoded = utils.decode(audio)
-                fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
-                unpacked = struct.unpack(fmt, decoded)
-            except (AssertionError, binascii.Error, struct.error):
-                raise FileIdInvalid from None
-            else:
-                if unpacked[0] != 9:
-                    media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
-
-                    if media_type:
-                        raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
-                    else:
-                        raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
-
-                media = types.InputMediaDocument(
-                    id=types.InputDocument(
-                        id=unpacked[2],
-                        access_hash=unpacked[3],
-                        file_reference=b""
-                    )
+        try:
+            if os.path.exists(audio):
+                thumb = None if thumb is None else self.save_file(thumb)
+                file = self.save_file(audio, progress=progress, progress_args=progress_args)
+                media = types.InputMediaUploadedDocument(
+                    mime_type=mimetypes.types_map.get("." + audio.split(".")[-1], "audio/mpeg"),
+                    file=file,
+                    thumb=thumb,
+                    attributes=[
+                        types.DocumentAttributeAudio(
+                            duration=duration,
+                            performer=performer,
+                            title=title
+                        ),
+                        types.DocumentAttributeFilename(os.path.basename(audio))
+                    ]
                 )
-
-        while True:
-            try:
-                r = self.send(
-                    functions.messages.SendMedia(
-                        peer=self.resolve_peer(chat_id),
-                        media=media,
-                        silent=disable_notification or None,
-                        reply_to_msg_id=reply_to_message_id,
-                        random_id=self.rnd_id(),
-                        reply_markup=reply_markup.write() if reply_markup else None,
-                        **style.parse(caption)
-                    )
+            elif audio.startswith("http"):
+                media = types.InputMediaDocumentExternal(
+                    url=audio
                 )
-            except FilePartMissing as e:
-                self.save_file(audio, file_id=file.id, file_part=e.x)
             else:
-                for i in r.updates:
-                    if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
-                        return pyrogram.Message._parse(
-                            self, i.message,
-                            {i.id: i for i in r.users},
-                            {i.id: i for i in r.chats}
+                try:
+                    decoded = utils.decode(audio)
+                    fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
+                    unpacked = struct.unpack(fmt, decoded)
+                except (AssertionError, binascii.Error, struct.error):
+                    raise FileIdInvalid from None
+                else:
+                    if unpacked[0] != 9:
+                        media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
+
+                        if media_type:
+                            raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
+                        else:
+                            raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
+
+                    media = types.InputMediaDocument(
+                        id=types.InputDocument(
+                            id=unpacked[2],
+                            access_hash=unpacked[3],
+                            file_reference=b""
                         )
+                    )
+
+            while True:
+                try:
+                    r = self.send(
+                        functions.messages.SendMedia(
+                            peer=self.resolve_peer(chat_id),
+                            media=media,
+                            silent=disable_notification or None,
+                            reply_to_msg_id=reply_to_message_id,
+                            random_id=self.rnd_id(),
+                            reply_markup=reply_markup.write() if reply_markup else None,
+                            **style.parse(caption)
+                        )
+                    )
+                except FilePartMissing as e:
+                    self.save_file(audio, file_id=file.id, file_part=e.x)
+                else:
+                    for i in r.updates:
+                        if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
+                            return pyrogram.Message._parse(
+                                self, i.message,
+                                {i.id: i for i in r.users},
+                                {i.id: i for i in r.chats}
+                            )
+        except BaseClient.StopTransmission:
+            return None
diff --git a/pyrogram/client/methods/messages/send_document.py b/pyrogram/client/methods/messages/send_document.py
index 393b094c..3a7e190d 100644
--- a/pyrogram/client/methods/messages/send_document.py
+++ b/pyrogram/client/methods/messages/send_document.py
@@ -42,7 +42,7 @@ class SendDocument(BaseClient):
                                           "pyrogram.ReplyKeyboardRemove",
                                           "pyrogram.ForceReply"] = None,
                       progress: callable = None,
-                      progress_args: tuple = ()) -> "pyrogram.Message":
+                      progress_args: tuple = ()) -> Union["pyrogram.Message", None]:
         """Use this method to send general files.
 
         Args:
@@ -107,6 +107,7 @@ class SendDocument(BaseClient):
 
         Returns:
             On success, the sent :obj:`Message <pyrogram.Message>` is returned.
+            In case the upload is deliberately stopped with :meth:`stop_transmission`, None is returned instead.
 
         Raises:
             :class:`Error <pyrogram.Error>` in case of a Telegram RPC error.
@@ -114,65 +115,68 @@ class SendDocument(BaseClient):
         file = None
         style = self.html if parse_mode.lower() == "html" else self.markdown
 
-        if os.path.exists(document):
-            thumb = None if thumb is None else self.save_file(thumb)
-            file = self.save_file(document, progress=progress, progress_args=progress_args)
-            media = types.InputMediaUploadedDocument(
-                mime_type=mimetypes.types_map.get("." + document.split(".")[-1], "text/plain"),
-                file=file,
-                thumb=thumb,
-                attributes=[
-                    types.DocumentAttributeFilename(os.path.basename(document))
-                ]
-            )
-        elif document.startswith("http"):
-            media = types.InputMediaDocumentExternal(
-                url=document
-            )
-        else:
-            try:
-                decoded = utils.decode(document)
-                fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
-                unpacked = struct.unpack(fmt, decoded)
-            except (AssertionError, binascii.Error, struct.error):
-                raise FileIdInvalid from None
-            else:
-                if unpacked[0] not in (5, 10):
-                    media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
-
-                    if media_type:
-                        raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
-                    else:
-                        raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
-
-                media = types.InputMediaDocument(
-                    id=types.InputDocument(
-                        id=unpacked[2],
-                        access_hash=unpacked[3],
-                        file_reference=b""
-                    )
+        try:
+            if os.path.exists(document):
+                thumb = None if thumb is None else self.save_file(thumb)
+                file = self.save_file(document, progress=progress, progress_args=progress_args)
+                media = types.InputMediaUploadedDocument(
+                    mime_type=mimetypes.types_map.get("." + document.split(".")[-1], "text/plain"),
+                    file=file,
+                    thumb=thumb,
+                    attributes=[
+                        types.DocumentAttributeFilename(os.path.basename(document))
+                    ]
                 )
-
-        while True:
-            try:
-                r = self.send(
-                    functions.messages.SendMedia(
-                        peer=self.resolve_peer(chat_id),
-                        media=media,
-                        silent=disable_notification or None,
-                        reply_to_msg_id=reply_to_message_id,
-                        random_id=self.rnd_id(),
-                        reply_markup=reply_markup.write() if reply_markup else None,
-                        **style.parse(caption)
-                    )
+            elif document.startswith("http"):
+                media = types.InputMediaDocumentExternal(
+                    url=document
                 )
-            except FilePartMissing as e:
-                self.save_file(document, file_id=file.id, file_part=e.x)
             else:
-                for i in r.updates:
-                    if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
-                        return pyrogram.Message._parse(
-                            self, i.message,
-                            {i.id: i for i in r.users},
-                            {i.id: i for i in r.chats}
+                try:
+                    decoded = utils.decode(document)
+                    fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
+                    unpacked = struct.unpack(fmt, decoded)
+                except (AssertionError, binascii.Error, struct.error):
+                    raise FileIdInvalid from None
+                else:
+                    if unpacked[0] not in (5, 10):
+                        media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
+
+                        if media_type:
+                            raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
+                        else:
+                            raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
+
+                    media = types.InputMediaDocument(
+                        id=types.InputDocument(
+                            id=unpacked[2],
+                            access_hash=unpacked[3],
+                            file_reference=b""
                         )
+                    )
+
+            while True:
+                try:
+                    r = self.send(
+                        functions.messages.SendMedia(
+                            peer=self.resolve_peer(chat_id),
+                            media=media,
+                            silent=disable_notification or None,
+                            reply_to_msg_id=reply_to_message_id,
+                            random_id=self.rnd_id(),
+                            reply_markup=reply_markup.write() if reply_markup else None,
+                            **style.parse(caption)
+                        )
+                    )
+                except FilePartMissing as e:
+                    self.save_file(document, file_id=file.id, file_part=e.x)
+                else:
+                    for i in r.updates:
+                        if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
+                            return pyrogram.Message._parse(
+                                self, i.message,
+                                {i.id: i for i in r.users},
+                                {i.id: i for i in r.chats}
+                            )
+        except BaseClient.StopTransmission:
+            return None
diff --git a/pyrogram/client/methods/messages/send_photo.py b/pyrogram/client/methods/messages/send_photo.py
index a5f858b2..84647245 100644
--- a/pyrogram/client/methods/messages/send_photo.py
+++ b/pyrogram/client/methods/messages/send_photo.py
@@ -41,7 +41,7 @@ class SendPhoto(BaseClient):
                                        "pyrogram.ReplyKeyboardRemove",
                                        "pyrogram.ForceReply"] = None,
                    progress: callable = None,
-                   progress_args: tuple = ()) -> "pyrogram.Message":
+                   progress_args: tuple = ()) -> Union["pyrogram.Message", None]:
         """Use this method to send photos.
 
         Args:
@@ -105,6 +105,7 @@ class SendPhoto(BaseClient):
 
         Returns:
             On success, the sent :obj:`Message <pyrogram.Message>` is returned.
+            In case the upload is deliberately stopped with :meth:`stop_transmission`, None is returned instead.
 
         Raises:
             :class:`Error <pyrogram.Error>` in case of a Telegram RPC error.
@@ -112,62 +113,65 @@ class SendPhoto(BaseClient):
         file = None
         style = self.html if parse_mode.lower() == "html" else self.markdown
 
-        if os.path.exists(photo):
-            file = self.save_file(photo, progress=progress, progress_args=progress_args)
-            media = types.InputMediaUploadedPhoto(
-                file=file,
-                ttl_seconds=ttl_seconds
-            )
-        elif photo.startswith("http"):
-            media = types.InputMediaPhotoExternal(
-                url=photo,
-                ttl_seconds=ttl_seconds
-            )
-        else:
-            try:
-                decoded = utils.decode(photo)
-                fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
-                unpacked = struct.unpack(fmt, decoded)
-            except (AssertionError, binascii.Error, struct.error):
-                raise FileIdInvalid from None
-            else:
-                if unpacked[0] != 2:
-                    media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
-
-                    if media_type:
-                        raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
-                    else:
-                        raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
-
-                media = types.InputMediaPhoto(
-                    id=types.InputPhoto(
-                        id=unpacked[2],
-                        access_hash=unpacked[3],
-                        file_reference=b""
-                    ),
+        try:
+            if os.path.exists(photo):
+                file = self.save_file(photo, progress=progress, progress_args=progress_args)
+                media = types.InputMediaUploadedPhoto(
+                    file=file,
                     ttl_seconds=ttl_seconds
                 )
-
-        while True:
-            try:
-                r = self.send(
-                    functions.messages.SendMedia(
-                        peer=self.resolve_peer(chat_id),
-                        media=media,
-                        silent=disable_notification or None,
-                        reply_to_msg_id=reply_to_message_id,
-                        random_id=self.rnd_id(),
-                        reply_markup=reply_markup.write() if reply_markup else None,
-                        **style.parse(caption)
-                    )
+            elif photo.startswith("http"):
+                media = types.InputMediaPhotoExternal(
+                    url=photo,
+                    ttl_seconds=ttl_seconds
                 )
-            except FilePartMissing as e:
-                self.save_file(photo, file_id=file.id, file_part=e.x)
             else:
-                for i in r.updates:
-                    if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
-                        return pyrogram.Message._parse(
-                            self, i.message,
-                            {i.id: i for i in r.users},
-                            {i.id: i for i in r.chats}
+                try:
+                    decoded = utils.decode(photo)
+                    fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
+                    unpacked = struct.unpack(fmt, decoded)
+                except (AssertionError, binascii.Error, struct.error):
+                    raise FileIdInvalid from None
+                else:
+                    if unpacked[0] != 2:
+                        media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
+
+                        if media_type:
+                            raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
+                        else:
+                            raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
+
+                    media = types.InputMediaPhoto(
+                        id=types.InputPhoto(
+                            id=unpacked[2],
+                            access_hash=unpacked[3],
+                            file_reference=b""
+                        ),
+                        ttl_seconds=ttl_seconds
+                    )
+
+            while True:
+                try:
+                    r = self.send(
+                        functions.messages.SendMedia(
+                            peer=self.resolve_peer(chat_id),
+                            media=media,
+                            silent=disable_notification or None,
+                            reply_to_msg_id=reply_to_message_id,
+                            random_id=self.rnd_id(),
+                            reply_markup=reply_markup.write() if reply_markup else None,
+                            **style.parse(caption)
                         )
+                    )
+                except FilePartMissing as e:
+                    self.save_file(photo, file_id=file.id, file_part=e.x)
+                else:
+                    for i in r.updates:
+                        if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
+                            return pyrogram.Message._parse(
+                                self, i.message,
+                                {i.id: i for i in r.users},
+                                {i.id: i for i in r.chats}
+                            )
+        except BaseClient.StopTransmission:
+            return None
diff --git a/pyrogram/client/methods/messages/send_sticker.py b/pyrogram/client/methods/messages/send_sticker.py
index aea8b057..e41c074e 100644
--- a/pyrogram/client/methods/messages/send_sticker.py
+++ b/pyrogram/client/methods/messages/send_sticker.py
@@ -38,7 +38,7 @@ class SendSticker(BaseClient):
                                          "pyrogram.ReplyKeyboardRemove",
                                          "pyrogram.ForceReply"] = None,
                      progress: callable = None,
-                     progress_args: tuple = ()) -> "pyrogram.Message":
+                     progress_args: tuple = ()) -> Union["pyrogram.Message", None]:
         """Use this method to send .webp stickers.
 
         Args:
@@ -89,69 +89,73 @@ class SendSticker(BaseClient):
 
         Returns:
             On success, the sent :obj:`Message <pyrogram.Message>` is returned.
+            In case the upload is deliberately stopped with :meth:`stop_transmission`, None is returned instead.
 
         Raises:
             :class:`Error <pyrogram.Error>` in case of a Telegram RPC error.
         """
         file = None
 
-        if os.path.exists(sticker):
-            file = self.save_file(sticker, progress=progress, progress_args=progress_args)
-            media = types.InputMediaUploadedDocument(
-                mime_type="image/webp",
-                file=file,
-                attributes=[
-                    types.DocumentAttributeFilename(os.path.basename(sticker))
-                ]
-            )
-        elif sticker.startswith("http"):
-            media = types.InputMediaDocumentExternal(
-                url=sticker
-            )
-        else:
-            try:
-                decoded = utils.decode(sticker)
-                fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
-                unpacked = struct.unpack(fmt, decoded)
-            except (AssertionError, binascii.Error, struct.error):
-                raise FileIdInvalid from None
-            else:
-                if unpacked[0] != 8:
-                    media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
-
-                    if media_type:
-                        raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
-                    else:
-                        raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
-
-                media = types.InputMediaDocument(
-                    id=types.InputDocument(
-                        id=unpacked[2],
-                        access_hash=unpacked[3],
-                        file_reference=b""
-                    )
+        try:
+            if os.path.exists(sticker):
+                file = self.save_file(sticker, progress=progress, progress_args=progress_args)
+                media = types.InputMediaUploadedDocument(
+                    mime_type="image/webp",
+                    file=file,
+                    attributes=[
+                        types.DocumentAttributeFilename(os.path.basename(sticker))
+                    ]
                 )
-
-        while True:
-            try:
-                r = self.send(
-                    functions.messages.SendMedia(
-                        peer=self.resolve_peer(chat_id),
-                        media=media,
-                        silent=disable_notification or None,
-                        reply_to_msg_id=reply_to_message_id,
-                        random_id=self.rnd_id(),
-                        reply_markup=reply_markup.write() if reply_markup else None,
-                        message=""
-                    )
+            elif sticker.startswith("http"):
+                media = types.InputMediaDocumentExternal(
+                    url=sticker
                 )
-            except FilePartMissing as e:
-                self.save_file(sticker, file_id=file.id, file_part=e.x)
             else:
-                for i in r.updates:
-                    if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
-                        return pyrogram.Message._parse(
-                            self, i.message,
-                            {i.id: i for i in r.users},
-                            {i.id: i for i in r.chats}
+                try:
+                    decoded = utils.decode(sticker)
+                    fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
+                    unpacked = struct.unpack(fmt, decoded)
+                except (AssertionError, binascii.Error, struct.error):
+                    raise FileIdInvalid from None
+                else:
+                    if unpacked[0] != 8:
+                        media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
+
+                        if media_type:
+                            raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
+                        else:
+                            raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
+
+                    media = types.InputMediaDocument(
+                        id=types.InputDocument(
+                            id=unpacked[2],
+                            access_hash=unpacked[3],
+                            file_reference=b""
                         )
+                    )
+
+            while True:
+                try:
+                    r = self.send(
+                        functions.messages.SendMedia(
+                            peer=self.resolve_peer(chat_id),
+                            media=media,
+                            silent=disable_notification or None,
+                            reply_to_msg_id=reply_to_message_id,
+                            random_id=self.rnd_id(),
+                            reply_markup=reply_markup.write() if reply_markup else None,
+                            message=""
+                        )
+                    )
+                except FilePartMissing as e:
+                    self.save_file(sticker, file_id=file.id, file_part=e.x)
+                else:
+                    for i in r.updates:
+                        if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
+                            return pyrogram.Message._parse(
+                                self, i.message,
+                                {i.id: i for i in r.users},
+                                {i.id: i for i in r.chats}
+                            )
+        except BaseClient.StopTransmission:
+            return None
diff --git a/pyrogram/client/methods/messages/send_video.py b/pyrogram/client/methods/messages/send_video.py
index 42f0d314..8b769054 100644
--- a/pyrogram/client/methods/messages/send_video.py
+++ b/pyrogram/client/methods/messages/send_video.py
@@ -46,7 +46,7 @@ class SendVideo(BaseClient):
                                        "pyrogram.ReplyKeyboardRemove",
                                        "pyrogram.ForceReply"] = None,
                    progress: callable = None,
-                   progress_args: tuple = ()) -> "pyrogram.Message":
+                   progress_args: tuple = ()) -> Union["pyrogram.Message", None]:
         """Use this method to send video files.
 
         Args:
@@ -123,6 +123,7 @@ class SendVideo(BaseClient):
 
         Returns:
             On success, the sent :obj:`Message <pyrogram.Message>` is returned.
+            In case the upload is deliberately stopped with :meth:`stop_transmission`, None is returned instead.
 
         Raises:
             :class:`Error <pyrogram.Error>` in case of a Telegram RPC error.
@@ -130,71 +131,74 @@ class SendVideo(BaseClient):
         file = None
         style = self.html if parse_mode.lower() == "html" else self.markdown
 
-        if os.path.exists(video):
-            thumb = None if thumb is None else self.save_file(thumb)
-            file = self.save_file(video, progress=progress, progress_args=progress_args)
-            media = types.InputMediaUploadedDocument(
-                mime_type=mimetypes.types_map[".mp4"],
-                file=file,
-                thumb=thumb,
-                attributes=[
-                    types.DocumentAttributeVideo(
-                        supports_streaming=supports_streaming or None,
-                        duration=duration,
-                        w=width,
-                        h=height
-                    ),
-                    types.DocumentAttributeFilename(os.path.basename(video))
-                ]
-            )
-        elif video.startswith("http"):
-            media = types.InputMediaDocumentExternal(
-                url=video
-            )
-        else:
-            try:
-                decoded = utils.decode(video)
-                fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
-                unpacked = struct.unpack(fmt, decoded)
-            except (AssertionError, binascii.Error, struct.error):
-                raise FileIdInvalid from None
-            else:
-                if unpacked[0] != 4:
-                    media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
-
-                    if media_type:
-                        raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
-                    else:
-                        raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
-
-                media = types.InputMediaDocument(
-                    id=types.InputDocument(
-                        id=unpacked[2],
-                        access_hash=unpacked[3],
-                        file_reference=b""
-                    )
+        try:
+            if os.path.exists(video):
+                thumb = None if thumb is None else self.save_file(thumb)
+                file = self.save_file(video, progress=progress, progress_args=progress_args)
+                media = types.InputMediaUploadedDocument(
+                    mime_type=mimetypes.types_map[".mp4"],
+                    file=file,
+                    thumb=thumb,
+                    attributes=[
+                        types.DocumentAttributeVideo(
+                            supports_streaming=supports_streaming or None,
+                            duration=duration,
+                            w=width,
+                            h=height
+                        ),
+                        types.DocumentAttributeFilename(os.path.basename(video))
+                    ]
                 )
-
-        while True:
-            try:
-                r = self.send(
-                    functions.messages.SendMedia(
-                        peer=self.resolve_peer(chat_id),
-                        media=media,
-                        silent=disable_notification or None,
-                        reply_to_msg_id=reply_to_message_id,
-                        random_id=self.rnd_id(),
-                        reply_markup=reply_markup.write() if reply_markup else None,
-                        **style.parse(caption)
-                    )
+            elif video.startswith("http"):
+                media = types.InputMediaDocumentExternal(
+                    url=video
                 )
-            except FilePartMissing as e:
-                self.save_file(video, file_id=file.id, file_part=e.x)
             else:
-                for i in r.updates:
-                    if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
-                        return pyrogram.Message._parse(
-                            self, i.message,
-                            {i.id: i for i in r.users},
-                            {i.id: i for i in r.chats}
+                try:
+                    decoded = utils.decode(video)
+                    fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
+                    unpacked = struct.unpack(fmt, decoded)
+                except (AssertionError, binascii.Error, struct.error):
+                    raise FileIdInvalid from None
+                else:
+                    if unpacked[0] != 4:
+                        media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
+
+                        if media_type:
+                            raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
+                        else:
+                            raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
+
+                    media = types.InputMediaDocument(
+                        id=types.InputDocument(
+                            id=unpacked[2],
+                            access_hash=unpacked[3],
+                            file_reference=b""
                         )
+                    )
+
+            while True:
+                try:
+                    r = self.send(
+                        functions.messages.SendMedia(
+                            peer=self.resolve_peer(chat_id),
+                            media=media,
+                            silent=disable_notification or None,
+                            reply_to_msg_id=reply_to_message_id,
+                            random_id=self.rnd_id(),
+                            reply_markup=reply_markup.write() if reply_markup else None,
+                            **style.parse(caption)
+                        )
+                    )
+                except FilePartMissing as e:
+                    self.save_file(video, file_id=file.id, file_part=e.x)
+                else:
+                    for i in r.updates:
+                        if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
+                            return pyrogram.Message._parse(
+                                self, i.message,
+                                {i.id: i for i in r.users},
+                                {i.id: i for i in r.chats}
+                            )
+        except BaseClient.StopTransmission:
+            return None
diff --git a/pyrogram/client/methods/messages/send_video_note.py b/pyrogram/client/methods/messages/send_video_note.py
index 5333311c..bbd17e98 100644
--- a/pyrogram/client/methods/messages/send_video_note.py
+++ b/pyrogram/client/methods/messages/send_video_note.py
@@ -42,7 +42,7 @@ class SendVideoNote(BaseClient):
                                             "pyrogram.ReplyKeyboardRemove",
                                             "pyrogram.ForceReply"] = None,
                         progress: callable = None,
-                        progress_args: tuple = ()) -> "pyrogram.Message":
+                        progress_args: tuple = ()) -> Union["pyrogram.Message", None]:
         """Use this method to send video messages.
 
         Args:
@@ -105,72 +105,76 @@ class SendVideoNote(BaseClient):
 
         Returns:
             On success, the sent :obj:`Message <pyrogram.Message>` is returned.
+            In case the upload is deliberately stopped with :meth:`stop_transmission`, None is returned instead.
 
         Raises:
             :class:`Error <pyrogram.Error>` in case of a Telegram RPC error.
         """
         file = None
 
-        if os.path.exists(video_note):
-            thumb = None if thumb is None else self.save_file(thumb)
-            file = self.save_file(video_note, progress=progress, progress_args=progress_args)
-            media = types.InputMediaUploadedDocument(
-                mime_type=mimetypes.types_map[".mp4"],
-                file=file,
-                thumb=thumb,
-                attributes=[
-                    types.DocumentAttributeVideo(
-                        round_message=True,
-                        duration=duration,
-                        w=length,
-                        h=length
-                    )
-                ]
-            )
-        else:
-            try:
-                decoded = utils.decode(video_note)
-                fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
-                unpacked = struct.unpack(fmt, decoded)
-            except (AssertionError, binascii.Error, struct.error):
-                raise FileIdInvalid from None
-            else:
-                if unpacked[0] != 13:
-                    media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
-
-                    if media_type:
-                        raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
-                    else:
-                        raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
-
-                media = types.InputMediaDocument(
-                    id=types.InputDocument(
-                        id=unpacked[2],
-                        access_hash=unpacked[3],
-                        file_reference=b""
-                    )
-                )
-
-        while True:
-            try:
-                r = self.send(
-                    functions.messages.SendMedia(
-                        peer=self.resolve_peer(chat_id),
-                        media=media,
-                        silent=disable_notification or None,
-                        reply_to_msg_id=reply_to_message_id,
-                        random_id=self.rnd_id(),
-                        reply_markup=reply_markup.write() if reply_markup else None,
-                        message=""
-                    )
-                )
-            except FilePartMissing as e:
-                self.save_file(video_note, file_id=file.id, file_part=e.x)
-            else:
-                for i in r.updates:
-                    if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
-                        return pyrogram.Message._parse(
-                            self, i.message,
-                            {i.id: i for i in r.users},
-                            {i.id: i for i in r.chats}
+        try:
+            if os.path.exists(video_note):
+                thumb = None if thumb is None else self.save_file(thumb)
+                file = self.save_file(video_note, progress=progress, progress_args=progress_args)
+                media = types.InputMediaUploadedDocument(
+                    mime_type=mimetypes.types_map[".mp4"],
+                    file=file,
+                    thumb=thumb,
+                    attributes=[
+                        types.DocumentAttributeVideo(
+                            round_message=True,
+                            duration=duration,
+                            w=length,
+                            h=length
                         )
+                    ]
+                )
+            else:
+                try:
+                    decoded = utils.decode(video_note)
+                    fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
+                    unpacked = struct.unpack(fmt, decoded)
+                except (AssertionError, binascii.Error, struct.error):
+                    raise FileIdInvalid from None
+                else:
+                    if unpacked[0] != 13:
+                        media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
+
+                        if media_type:
+                            raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
+                        else:
+                            raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
+
+                    media = types.InputMediaDocument(
+                        id=types.InputDocument(
+                            id=unpacked[2],
+                            access_hash=unpacked[3],
+                            file_reference=b""
+                        )
+                    )
+
+            while True:
+                try:
+                    r = self.send(
+                        functions.messages.SendMedia(
+                            peer=self.resolve_peer(chat_id),
+                            media=media,
+                            silent=disable_notification or None,
+                            reply_to_msg_id=reply_to_message_id,
+                            random_id=self.rnd_id(),
+                            reply_markup=reply_markup.write() if reply_markup else None,
+                            message=""
+                        )
+                    )
+                except FilePartMissing as e:
+                    self.save_file(video_note, file_id=file.id, file_part=e.x)
+                else:
+                    for i in r.updates:
+                        if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
+                            return pyrogram.Message._parse(
+                                self, i.message,
+                                {i.id: i for i in r.users},
+                                {i.id: i for i in r.chats}
+                            )
+        except BaseClient.StopTransmission:
+            return None
diff --git a/pyrogram/client/methods/messages/send_voice.py b/pyrogram/client/methods/messages/send_voice.py
index 74a30ccf..b69d7d3a 100644
--- a/pyrogram/client/methods/messages/send_voice.py
+++ b/pyrogram/client/methods/messages/send_voice.py
@@ -42,7 +42,7 @@ class SendVoice(BaseClient):
                                        "pyrogram.ReplyKeyboardRemove",
                                        "pyrogram.ForceReply"] = None,
                    progress: callable = None,
-                   progress_args: tuple = ()) -> "pyrogram.Message":
+                   progress_args: tuple = ()) -> Union["pyrogram.Message", None]:
         """Use this method to send audio files.
 
         Args:
@@ -104,6 +104,7 @@ class SendVoice(BaseClient):
 
         Returns:
             On success, the sent :obj:`Message <pyrogram.Message>` is returned.
+            In case the upload is deliberately stopped with :meth:`stop_transmission`, None is returned instead.
 
         Raises:
             :class:`Error <pyrogram.Error>` in case of a Telegram RPC error.
@@ -111,66 +112,69 @@ class SendVoice(BaseClient):
         file = None
         style = self.html if parse_mode.lower() == "html" else self.markdown
 
-        if os.path.exists(voice):
-            file = self.save_file(voice, progress=progress, progress_args=progress_args)
-            media = types.InputMediaUploadedDocument(
-                mime_type=mimetypes.types_map.get("." + voice.split(".")[-1], "audio/mpeg"),
-                file=file,
-                attributes=[
-                    types.DocumentAttributeAudio(
-                        voice=True,
-                        duration=duration
-                    )
-                ]
-            )
-        elif voice.startswith("http"):
-            media = types.InputMediaDocumentExternal(
-                url=voice
-            )
-        else:
-            try:
-                decoded = utils.decode(voice)
-                fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
-                unpacked = struct.unpack(fmt, decoded)
-            except (AssertionError, binascii.Error, struct.error):
-                raise FileIdInvalid from None
-            else:
-                if unpacked[0] != 3:
-                    media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
-
-                    if media_type:
-                        raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
-                    else:
-                        raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
-
-                media = types.InputMediaDocument(
-                    id=types.InputDocument(
-                        id=unpacked[2],
-                        access_hash=unpacked[3],
-                        file_reference=b""
-                    )
-                )
-
-        while True:
-            try:
-                r = self.send(
-                    functions.messages.SendMedia(
-                        peer=self.resolve_peer(chat_id),
-                        media=media,
-                        silent=disable_notification or None,
-                        reply_to_msg_id=reply_to_message_id,
-                        random_id=self.rnd_id(),
-                        reply_markup=reply_markup.write() if reply_markup else None,
-                        **style.parse(caption)
-                    )
-                )
-            except FilePartMissing as e:
-                self.save_file(voice, file_id=file.id, file_part=e.x)
-            else:
-                for i in r.updates:
-                    if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
-                        return pyrogram.Message._parse(
-                            self, i.message,
-                            {i.id: i for i in r.users},
-                            {i.id: i for i in r.chats}
+        try:
+            if os.path.exists(voice):
+                file = self.save_file(voice, progress=progress, progress_args=progress_args)
+                media = types.InputMediaUploadedDocument(
+                    mime_type=mimetypes.types_map.get("." + voice.split(".")[-1], "audio/mpeg"),
+                    file=file,
+                    attributes=[
+                        types.DocumentAttributeAudio(
+                            voice=True,
+                            duration=duration
                         )
+                    ]
+                )
+            elif voice.startswith("http"):
+                media = types.InputMediaDocumentExternal(
+                    url=voice
+                )
+            else:
+                try:
+                    decoded = utils.decode(voice)
+                    fmt = "<iiqqqqi" if len(decoded) > 24 else "<iiqq"
+                    unpacked = struct.unpack(fmt, decoded)
+                except (AssertionError, binascii.Error, struct.error):
+                    raise FileIdInvalid from None
+                else:
+                    if unpacked[0] != 3:
+                        media_type = BaseClient.MEDIA_TYPE_ID.get(unpacked[0], None)
+
+                        if media_type:
+                            raise FileIdInvalid("The file_id belongs to a {}".format(media_type))
+                        else:
+                            raise FileIdInvalid("Unknown media type: {}".format(unpacked[0]))
+
+                    media = types.InputMediaDocument(
+                        id=types.InputDocument(
+                            id=unpacked[2],
+                            access_hash=unpacked[3],
+                            file_reference=b""
+                        )
+                    )
+
+            while True:
+                try:
+                    r = self.send(
+                        functions.messages.SendMedia(
+                            peer=self.resolve_peer(chat_id),
+                            media=media,
+                            silent=disable_notification or None,
+                            reply_to_msg_id=reply_to_message_id,
+                            random_id=self.rnd_id(),
+                            reply_markup=reply_markup.write() if reply_markup else None,
+                            **style.parse(caption)
+                        )
+                    )
+                except FilePartMissing as e:
+                    self.save_file(voice, file_id=file.id, file_part=e.x)
+                else:
+                    for i in r.updates:
+                        if isinstance(i, (types.UpdateNewMessage, types.UpdateNewChannelMessage)):
+                            return pyrogram.Message._parse(
+                                self, i.message,
+                                {i.id: i for i in r.users},
+                                {i.id: i for i in r.chats}
+                            )
+        except BaseClient.StopTransmission:
+            return None