
    qi M                     X   d Z ddlmZ ddlmZ ddlmZ ddlm	Z
  ej                         ZddlmZ ddlmZ  ej                         j%                  d	      Z e       Z e
j,                  ee        e
j.                  ed
e       ej0                  dk(  rded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        d ed!   _        d"ed!   _        d#ed$   _        d%ed$   _        d&ed'   _        d(ed'   _        d)ed*   _        d+ed*   _        d,ed-   _        d.ed-   _        d/ed0   _        d1ed0   _        d2ed3   _        d4ed3   _        d5ed6   _        d7ed6   _        d8ed9   _        d:ed9   _        d;ed<   _        d=ed<   _        d>ed?   _        d@ed?   _        dAedB   _        dCedB   _        dDedE   _        dFedE   _        dGedH   _        dIedH   _        dJedK   _        dLedK   _        dMedN   _        dOedN   _        dPedQ   _        dRedQ   _        dSedT   _        dUedT   _        dVedW   _        dXedW   _        dYedZ   _        d[edZ   _        d\ed]   _        d^ed]   _        d_ed`   _        daed`   _        dbedc   _        ddedc   _        deedf   _        dgedf   _        dhedi   _        djedi   _        dkedl   _        dmedl   _        dnedo   _        dpedo   _        dqedr   _        dsedr   _        dtedu   _        dvedu   _        dwedx   _        dyedx   _        dzed{   _        d|ed{   _        d}ed~   _        ded~   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        ded   _        yy)zGenerated protocol buffer code.    )
descriptor)descriptor_pool)symbol_database)builder   )
handle_pb2)e2ee_pb2s  
data_stream.protolivekit.protohandle.proto
e2ee.proto"s
OwnedTextStreamReader-
handle (2.livekit.proto.FfiOwnedHandle+
info (2.livekit.proto.TextStreamInfo"?
&TextStreamReaderReadIncrementalRequest
reader_handle (")
'TextStreamReaderReadIncrementalResponse"Q
TextStreamReaderReadAllRequest
reader_handle (
request_async_id ("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"Q
ByteStreamReaderReadAllRequest
reader_handle (
request_async_id ("3
ByteStreamReaderReadAllResponse
async_id ("}
ByteStreamReaderReadAllCallback
async_id (
content (H +
error (2.livekit.proto.StreamErrorH B
result"
"ByteStreamReaderWriteToFileRequest
reader_handle (
request_async_id (
	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 (	
request_async_id ("*
StreamSendFileResponse
async_id ("
StreamSendFileCallback
async_id (-
info (2.livekit.proto.ByteStreamInfoH +
error (2.livekit.proto.StreamErrorH B
result"
StreamSendBytesRequest 
local_participant_handle (1
options (2 .livekit.proto.StreamByteOptions
bytes (
request_async_id ("+
StreamSendBytesResponse
async_id ("
StreamSendBytesCallback
async_id (-
info (2.livekit.proto.ByteStreamInfoH +
error (2.livekit.proto.StreamErrorH B
result"
StreamSendTextRequest 
local_participant_handle (1
options (2 .livekit.proto.StreamTextOptions
text (	
request_async_id ("*
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"
ByteStreamOpenRequest 
local_participant_handle (1
options (2 .livekit.proto.StreamByteOptions
request_async_id ("*
ByteStreamOpenResponse
async_id ("
ByteStreamOpenCallback
async_id (6
writer (2$.livekit.proto.OwnedByteStreamWriterH +
error (2.livekit.proto.StreamErrorH B
result"^
ByteStreamWriterWriteRequest
writer_handle (
bytes (
request_async_id ("1
ByteStreamWriterWriteResponse
async_id ("\
ByteStreamWriterWriteCallback
async_id ()
error (2.livekit.proto.StreamError"_
ByteStreamWriterCloseRequest
writer_handle (
reason (	
request_async_id ("1
ByteStreamWriterCloseResponse
async_id ("\
ByteStreamWriterCloseCallback
async_id ()
error (2.livekit.proto.StreamError"s
OwnedTextStreamWriter-
handle (2.livekit.proto.FfiOwnedHandle+
info (2.livekit.proto.TextStreamInfo"
TextStreamOpenRequest 
local_participant_handle (1
options (2 .livekit.proto.StreamTextOptions
request_async_id ("*
TextStreamOpenResponse
async_id ("
TextStreamOpenCallback
async_id (6
writer (2$.livekit.proto.OwnedTextStreamWriterH +
error (2.livekit.proto.StreamErrorH B
result"]
TextStreamWriterWriteRequest
writer_handle (
text (	
request_async_id ("1
TextStreamWriterWriteResponse
async_id ("\
TextStreamWriterWriteCallback
async_id ()
error (2.livekit.proto.StreamError"_
TextStreamWriterCloseRequest
writer_handle (
reason (	
request_async_id ("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 (6
encryption_type (2.livekit.proto.EncryptionType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 (	6
encryption_type (2.livekit.proto.EncryptionType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_ATTRIBUTESENTRY>   _OWNEDTEXTSTREAMREADER      '_TEXTSTREAMREADERREADINCREMENTALREQUEST      (_TEXTSTREAMREADERREADINCREMENTALRESPONSEi  i  _TEXTSTREAMREADERREADALLREQUESTip  ir   _TEXTSTREAMREADERREADALLRESPONSEi  i   _TEXTSTREAMREADERREADALLCALLBACKi$  i'  _TEXTSTREAMREADEREVENTi  i  _TEXTSTREAMREADERCHUNKRECEIVEDi  i  _TEXTSTREAMREADEREOSiN  iP  _OWNEDBYTESTREAMREADERi  i  '_BYTESTREAMREADERREADINCREMENTALREQUESTi  i  (_BYTESTREAMREADERREADINCREMENTALRESPONSEi/  i1  _BYTESTREAMREADERREADALLREQUESTi  i   _BYTESTREAMREADERREADALLRESPONSEi  i   _BYTESTREAMREADERREADALLCALLBACKi6  i8  #_BYTESTREAMREADERWRITETOFILEREQUESTi  i  $_BYTESTREAMREADERWRITETOFILERESPONSEi  i  $_BYTESTREAMREADERWRITETOFILECALLBACKiv  iy  _BYTESTREAMREADEREVENTi,  i.  _BYTESTREAMREADERCHUNKRECEIVEDi^  i`  _BYTESTREAMREADEREOSi  i  _STREAMSENDFILEREQUESTi<  i>  _STREAMSENDFILERESPONSEih  ik  _STREAMSENDFILECALLBACKi  i  _STREAMSENDBYTESREQUESTi	  i	  _STREAMSENDBYTESRESPONSEi	  i	  _STREAMSENDBYTESCALLBACKiU
  iX
  _STREAMSENDTEXTREQUESTi
  i
  _STREAMSENDTEXTRESPONSEi  i  _STREAMSENDTEXTCALLBACKi  i  _OWNEDBYTESTREAMWRITERi   i#  _BYTESTREAMOPENREQUESTi  i  _BYTESTREAMOPENRESPONSEi  i  _BYTESTREAMOPENCALLBACKiq  is  _BYTESTREAMWRITERWRITEREQUESTi  i  _BYTESTREAMWRITERWRITERESPONSEi  i  _BYTESTREAMWRITERWRITECALLBACKib  id  _BYTESTREAMWRITERCLOSEREQUESTi  i  _BYTESTREAMWRITERCLOSERESPONSEi  i  _BYTESTREAMWRITERCLOSECALLBACKiT  iV  _OWNEDTEXTSTREAMWRITERi  i  _TEXTSTREAMOPENREQUESTiR  iT  _TEXTSTREAMOPENRESPONSEi~  i  _TEXTSTREAMOPENCALLBACKi  i  _TEXTSTREAMWRITERWRITEREQUESTiy  i{  _TEXTSTREAMWRITERWRITERESPONSEi  i  _TEXTSTREAMWRITERWRITECALLBACKi
  i  _TEXTSTREAMWRITERCLOSEREQUESTik  im  _TEXTSTREAMWRITERCLOSERESPONSEi  i  _TEXTSTREAMWRITERCLOSECALLBACKi  i  _TEXTSTREAMINFOi   i  i  i  _TEXTSTREAMINFO_OPERATIONTYPEi  _BYTESTREAMINFOi-  i0  _STREAMTEXTOPTIONSi  i  _STREAMBYTEOPTIONSi  i  _STREAMERRORi  )__doc__google.protobufr   _descriptorr   _descriptor_poolr   _symbol_databasegoogle.protobuf.internalr   _builderDefault_sym_db r   handle__pb2r	   	e2ee__pb2AddSerializedFiler   globals_globalsBuildMessageAndEnumDescriptorsBuildTopDescriptorsAndMessages_USE_C_DESCRIPTORS_options_serialized_options_serialized_start_serialized_end     T/opt/pipecat/venv/lib/python3.12/site-packages/livekit/rtc/_proto/data_stream_pb2.py<module>rf      s  
 & 5 ? ? 8 #

"
"
$ ( # &%%'99  ;Je  Ke
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GFJ(45EIM(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:($%58<($%76:($%59=(%&87;(%&69=(%&87;(%&67;(#$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(>,+/(>*E +rd   