
    q	h_F                     
   S r SSKJr  SSKJr  SSKJr  SSKJ	r
  \R                  " 5       rSSKJr  \R                  " 5       R!                  S5      r\" 5       r\
R(                  " \\5        \
R*                  " \S	\5        \R,                  S
:X  Ga  S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S    l        S!\S    l        S"\S#   l        S$\S#   l        S%\S&   l        S'\S&   l        S(\S)   l        S*\S)   l        S+\S,   l        S-\S,   l        S.\S/   l        S0\S/   l        S1\S2   l        S3\S2   l        S4\S5   l        S6\S5   l        S7\S8   l        S9\S8   l        S:\S;   l        S<\S;   l        S=\S>   l        S?\S>   l        S@\SA   l        SB\SA   l        SC\SD   l        SE\SD   l        SF\SG   l        SH\SG   l        SI\SJ   l        SK\SJ   l        SL\SM   l        SN\SM   l        SO\SP   l        SQ\SP   l        SR\SS   l        ST\SS   l        SU\SV   l        SW\SV   l        SX\SY   l        SZ\SY   l        S[\S\   l        S]\S\   l        S^\S_   l        S`\S_   l        Sa\Sb   l        Sc\Sb   l        Sd\Se   l        Sf\Se   l        Sg\Sh   l        Si\Sh   l        Sj\Sk   l        Sl\Sk   l        Sm\Sn   l        So\Sn   l        Sp\Sq   l        Sr\Sq   l        Ss\St   l        Su\St   l        Sv\Sw   l        Sx\Sw   l        Sy\Sz   l        S{\Sz   l        S|\S}   l        S~\S}   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        S\S   l        gg)zGenerated protocol buffer code.    )
descriptor)descriptor_pool)symbol_database)builder   )
handle_pb2s  
data_stream.protolivekit.protohandle.proto"s
OwnedTextStreamReader-
handle (2.livekit.proto.FfiOwnedHandle+
info (2.livekit.proto.TextStreamInfo"?
&TextStreamReaderReadIncrementalRequest
reader_handle (")
'TextStreamReaderReadIncrementalResponse"7
TextStreamReaderReadAllRequest
reader_handle ("3
TextStreamReaderReadAllResponse
async_id ("}
TextStreamReaderReadAllCallback
async_id (
content (	H +
error (2.livekit.proto.StreamErrorH B
result"
TextStreamReaderEvent
reader_handle (F
chunk_received (2,.livekit.proto.TextStreamReaderChunkReceivedH 1
eos (2".livekit.proto.TextStreamReaderEOSH B
detail"0
TextStreamReaderChunkReceived
content (	"@
TextStreamReaderEOS)
error (2.livekit.proto.StreamError"s
OwnedByteStreamReader-
handle (2.livekit.proto.FfiOwnedHandle+
info (2.livekit.proto.ByteStreamInfo"?
&ByteStreamReaderReadIncrementalRequest
reader_handle (")
'ByteStreamReaderReadIncrementalResponse"7
ByteStreamReaderReadAllRequest
reader_handle ("3
ByteStreamReaderReadAllResponse
async_id ("}
ByteStreamReaderReadAllCallback
async_id (
content (H +
error (2.livekit.proto.StreamErrorH B
result"e
"ByteStreamReaderWriteToFileRequest
reader_handle (
	directory (	
name_override (	"7
#ByteStreamReaderWriteToFileResponse
async_id ("
#ByteStreamReaderWriteToFileCallback
async_id (
	file_path (	H +
error (2.livekit.proto.StreamErrorH B
result"
ByteStreamReaderEvent
reader_handle (F
chunk_received (2,.livekit.proto.ByteStreamReaderChunkReceivedH 1
eos (2".livekit.proto.ByteStreamReaderEOSH B
detail"0
ByteStreamReaderChunkReceived
content ("@
ByteStreamReaderEOS)
error (2.livekit.proto.StreamError"
StreamSendFileRequest 
local_participant_handle (1
options (2 .livekit.proto.StreamByteOptions
	file_path (	"*
StreamSendFileResponse
async_id ("
StreamSendFileCallback
async_id (-
info (2.livekit.proto.ByteStreamInfoH +
error (2.livekit.proto.StreamErrorH B
result"z
StreamSendTextRequest 
local_participant_handle (1
options (2 .livekit.proto.StreamTextOptions
text (	"*
StreamSendTextResponse
async_id ("
StreamSendTextCallback
async_id (-
info (2.livekit.proto.TextStreamInfoH +
error (2.livekit.proto.StreamErrorH B
result"s
OwnedByteStreamWriter-
handle (2.livekit.proto.FfiOwnedHandle+
info (2.livekit.proto.ByteStreamInfo"l
ByteStreamOpenRequest 
local_participant_handle (1
options (2 .livekit.proto.StreamByteOptions"*
ByteStreamOpenResponse
async_id ("
ByteStreamOpenCallback
async_id (6
writer (2$.livekit.proto.OwnedByteStreamWriterH +
error (2.livekit.proto.StreamErrorH B
result"D
ByteStreamWriterWriteRequest
writer_handle (
bytes ("1
ByteStreamWriterWriteResponse
async_id ("\
ByteStreamWriterWriteCallback
async_id ()
error (2.livekit.proto.StreamError"E
ByteStreamWriterCloseRequest
writer_handle (
reason (	"1
ByteStreamWriterCloseResponse
async_id ("\
ByteStreamWriterCloseCallback
async_id ()
error (2.livekit.proto.StreamError"s
OwnedTextStreamWriter-
handle (2.livekit.proto.FfiOwnedHandle+
info (2.livekit.proto.TextStreamInfo"l
TextStreamOpenRequest 
local_participant_handle (1
options (2 .livekit.proto.StreamTextOptions"*
TextStreamOpenResponse
async_id ("
TextStreamOpenCallback
async_id (6
writer (2$.livekit.proto.OwnedTextStreamWriterH +
error (2.livekit.proto.StreamErrorH B
result"C
TextStreamWriterWriteRequest
writer_handle (
text (	"1
TextStreamWriterWriteResponse
async_id ("\
TextStreamWriterWriteCallback
async_id ()
error (2.livekit.proto.StreamError"E
TextStreamWriterCloseRequest
writer_handle (
reason (	"1
TextStreamWriterCloseResponse
async_id ("\
TextStreamWriterCloseCallback
async_id ()
error (2.livekit.proto.StreamError"
TextStreamInfo
	stream_id (	
	timestamp (
	mime_type (	
topic (	
total_length (A

attributes (2-.livekit.proto.TextStreamInfo.AttributesEntryC
operation_type (2+.livekit.proto.TextStreamInfo.OperationType
version (
reply_to_stream_id	 (	
attached_stream_ids
 (	
	generated (1
AttributesEntry
key (	
value (	:8"A
OperationType

CREATE 

UPDATE

DELETE
REACTION"
ByteStreamInfo
	stream_id (	
	timestamp (
	mime_type (	
topic (	
total_length (A

attributes (2-.livekit.proto.ByteStreamInfo.AttributesEntry
name (	1
AttributesEntry
key (	
value (	:8"
StreamTextOptions
topic (	D

attributes (20.livekit.proto.StreamTextOptions.AttributesEntry
destination_identities (	

id (	C
operation_type (2+.livekit.proto.TextStreamInfo.OperationType
version (
reply_to_stream_id (	
attached_stream_ids (	
	generated	 (1
AttributesEntry
key (	
value (	:8"
StreamByteOptions
topic (	D

attributes (20.livekit.proto.StreamByteOptions.AttributesEntry
destination_identities (	

id (	
name (	
	mime_type (	
total_length (1
AttributesEntry
key (	
value (	:8""
StreamError
description (	BLiveKit.Protodata_stream_pb2FN
DESCRIPTORs   LiveKit.Proto_TEXTSTREAMINFO_ATTRIBUTESENTRYs   8_BYTESTREAMINFO_ATTRIBUTESENTRY"_STREAMTEXTOPTIONS_ATTRIBUTESENTRY"_STREAMBYTEOPTIONS_ATTRIBUTESENTRY2   _OWNEDTEXTSTREAMREADER      '_TEXTSTREAMREADERREADINCREMENTALREQUEST      (_TEXTSTREAMREADERREADINCREMENTALRESPONSEi  i  _TEXTSTREAMREADERREADALLREQUESTiJ  iL   _TEXTSTREAMREADERREADALLRESPONSEi  i   _TEXTSTREAMREADERREADALLCALLBACKi  i  _TEXTSTREAMREADEREVENTi  i  _TEXTSTREAMREADERCHUNKRECEIVEDi  i  _TEXTSTREAMREADEREOSi(  i*  _OWNEDBYTESTREAMREADERi  i  '_BYTESTREAMREADERREADINCREMENTALREQUESTi  i  (_BYTESTREAMREADERREADINCREMENTALRESPONSEi	  i  _BYTESTREAMREADERREADALLREQUESTiB  iD   _BYTESTREAMREADERREADALLRESPONSEiw  iy   _BYTESTREAMREADERREADALLCALLBACKi  i  #_BYTESTREAMREADERWRITETOFILEREQUESTi]  i_  $_BYTESTREAMREADERWRITETOFILERESPONSEi  i  $_BYTESTREAMREADERWRITETOFILECALLBACKi  i  _BYTESTREAMREADEREVENTi  i  _BYTESTREAMREADERCHUNKRECEIVEDi  i  _BYTESTREAMREADEREOSiF  iH  _STREAMSENDFILEREQUESTi  i  _STREAMSENDFILERESPONSEi  i  _STREAMSENDFILECALLBACKi  i  _STREAMSENDTEXTREQUESTi	  i	  _STREAMSENDTEXTRESPONSEi.	  i1	  _STREAMSENDTEXTCALLBACKi	  i	  _OWNEDBYTESTREAMWRITERi6
  i8
  _BYTESTREAMOPENREQUESTi
  i
  _BYTESTREAMOPENRESPONSEi
  i
  _BYTESTREAMOPENCALLBACKil  in  _BYTESTREAMWRITERWRITEREQUESTi  i  _BYTESTREAMWRITERWRITERESPONSEi  i  _BYTESTREAMWRITERWRITECALLBACKiC  iE  _BYTESTREAMWRITERCLOSEREQUESTi  i  _BYTESTREAMWRITERCLOSERESPONSEi  i  _BYTESTREAMWRITERCLOSECALLBACKi  i  _OWNEDTEXTSTREAMWRITERi  i  _TEXTSTREAMOPENREQUESTi  i   _TEXTSTREAMOPENRESPONSEi*  i-  _TEXTSTREAMOPENCALLBACKi  i  _TEXTSTREAMWRITERWRITEREQUESTi  i  _TEXTSTREAMWRITERWRITERESPONSEi>  i@  _TEXTSTREAMWRITERWRITECALLBACKi  i  _TEXTSTREAMWRITERCLOSEREQUESTi  i  _TEXTSTREAMWRITERCLOSERESPONSEi  i  _TEXTSTREAMWRITERCLOSECALLBACKit  iw  _TEXTSTREAMINFOi@  i  i  i  _TEXTSTREAMINFO_OPERATIONTYPEiC  _BYTESTREAMINFOi5  i8  _STREAMTEXTOPTIONSi  i  _STREAMBYTEOPTIONSi  i  _STREAMERRORi  )__doc__google.protobufr   _descriptorr   _descriptor_poolr   _symbol_databasegoogle.protobuf.internalr   _builderDefault_sym_db r   handle__pb2AddSerializedFiler
   globals_globalsBuildMessageAndEnumDescriptorsBuildTopDescriptorsAndMessages_USE_C_DESCRIPTORS_options_serialized_options_serialized_start_serialized_end     T/var/www/html/env/lib/python3.13/site-packages/livekit/rtc/_proto/data_stream_pb2.py<module>ra      sQ  
 & 5 ? ? 8 
"
"
$ ( %%'99  ;[P  \P
9  ' '
H =  ' '
4Ex P!!U*$((<!/I(<,9=(,-6DL(,-A9=(,-6DL(,-A<@(/09GO(/0D<@(/09GO(/0D79(#$658(#$4HK(45GFI(45EIL(56HGJ(56F@C(,-?>A(,-=AD(-.@?B(-.>AD(-.@?B(-.>7:(#$658(#$4?B(+,>=@(+,<58(!"436(!"27:(#$658(#$4HK(45GFI(45EIL(56HGK(56F@D(,-?>B(,-=AE(-.@?C(-.>AE(-.@?C(-.>DH(01CBF(01AEI(12DCG(12BEI(12DCG(12B7;(#$659(#$4?C(+,>=A(+,<59(!"437(!"27;(#$659(#$48<($%76:($%58<($%76:($%57;(#$659(#$48<($%76:($%58<($%76:($%57;(#$659(#$47;(#$659(#$48<($%76:($%58<($%76:($%5>B(*+=<@(*+;?C(+,>=A(+,<?C(+,>=A(+,<>B(*+=<@(*+;?C(+,>=A(+,<?C(+,>=A(+,<7;(#$659(#$47;(#$659(#$48<($%76:($%58<($%76:($%5>B(*+=<@(*+;?C(+,>=A(+,<?C(+,>=A(+,<>B(*+=<@(*+;?C(+,>=A(+,<?C(+,>=A(+,<04(/.2(-@D(,-?>B(,-=>B(*+=<@(*+;04(/.2(-@D(,-?>B(,-=37( 215( 0CG(/0BAE(/0@37( 215( 0CG(/0BAE(/0@-1(>,+/(>*y +r_   