@@ -707,7 +707,7 @@ async def send_text(
707707 topic : str = "" ,
708708 attributes : Optional [Dict [str , str ]] = None ,
709709 reply_to_id : str | None = None ,
710- compress : bool | None = None ,
710+ compress : bool = True ,
711711 ) -> TextStreamInfo :
712712 req = proto_ffi .FfiRequest ()
713713 req .send_text .local_participant_handle = self ._ffi_handle .handle
@@ -720,8 +720,7 @@ async def send_text(
720720 options .destination_identities .extend (destination_identities )
721721 if reply_to_id :
722722 options .reply_to_stream_id = reply_to_id
723- if compress is not None :
724- options .compress = compress
723+ options .compress = compress
725724 options .sender_identity = self .identity
726725
727726 queue = FfiClient .instance .queue .subscribe ()
@@ -776,7 +775,7 @@ async def send_file(
776775 destination_identities : Optional [List [str ]] = None ,
777776 attributes : Optional [Dict [str , str ]] = None ,
778777 stream_id : str | None = None ,
779- compress : bool | None = None ,
778+ compress : bool = True ,
780779 ) -> ByteStreamInfo :
781780 file_name = os .path .basename (file_path )
782781 mime_type , _ = mimetypes .guess_type (file_path )
@@ -796,8 +795,7 @@ async def send_file(
796795 options .destination_identities .extend (destination_identities )
797796 if stream_id is not None :
798797 options .id = stream_id
799- if compress is not None :
800- options .compress = compress
798+ options .compress = compress
801799 options .sender_identity = self .identity
802800
803801 queue = FfiClient .instance .queue .subscribe ()
0 commit comments