ɝjddlZddlmZddlmZmZddlmZddlm Z eje Z eGddZ Gd d eZdd lmZy) N) dataclass)OptionalUnion)AsyncIOEventEmitter)InvalidStateErrorceZdZUdZdZeed< dZee ed< dZ ee ed< dZ e ed< dZ eed < d Ze ed < dZee ed <y) RTCDataChannelParameterszy The :class:`RTCDataChannelParameters` dictionary describes the configuration of an :class:`RTCDataChannel`. labelNmaxPacketLifeTimemaxRetransmitsTorderedprotocolF negotiatedid)__name__ __module__ __qualname____doc__r str__annotations__r rintrrboolrrrV/home/uftp/webrtc-recorder/.venv/lib/python3.12/site-packages/aiortc/rtcdatachannel.pyr r sv E3O)'+x}+P$(NHSM(?GTHHc)J3B rr c eZdZdZ d"dddededdffd Zedefd Z edefd Z e jd eddfd Z edefd Z ede efdZedefdZedefdZede efdZede efdZedefdZedefdZed#dZd$dZdeeefddfdZdeddfdZdeddfdZdeddfdZded eddfd!ZxZ S)%RTCDataChannela The :class:`RTCDataChannel` interface represents a network channel which can be used for bidirectional peer-to-peer transfers of arbitrary data. :param transport: An :class:`RTCSctpTransport`. :param parameters: An :class:`RTCDataChannelParameters`. transportRTCSctpTransport parameters send_openreturnNct|d|_d|_|j|_||_d|_||_||_ |j jr5|j |j dks|j dkDr td|j js0|jr#d|_ |jj|yy|jj|y)Nr connectingizEID must be in range 0-65534 if data channel is negotiated out-of-bandF)super__init___RTCDataChannel__bufferedAmount+_RTCDataChannel__bufferedAmountLowThresholdr_RTCDataChannel__id_RTCDataChannel__parameters_RTCDataChannel__readyState_RTCDataChannel__transport_RTCDataChannel__send_openr ValueError_data_channel_open_data_channel_add_negotiated)selfr r"r# __class__s rr(zRTCDataChannel.__init__8s  !,-)MM &($$    ' ' II Q$))e2CW   ++#(   33D9     9 9$ ?rc|jS)z` The number of bytes of data currently queued to be sent over the data channel. )r)r3s rbufferedAmountzRTCDataChannel.bufferedAmountUs $$$rc|jS)zY The number of bytes of buffered outgoing data that is considered "low". )r*r6s rbufferedAmountLowThresholdz)RTCDataChannel.bufferedAmountLowThreshold\s 000rvaluec<|dks|dkDr td||_y)Nrlz:bufferedAmountLowThreshold must be in range 0 - 4294967295)r0r*)r3r:s rr9z)RTCDataChannel.bufferedAmountLowThresholdcs* 19 *L -2)rc.|jjS)zB Whether data channel was negotiated out-of-band. )r,rr6s rrzRTCDataChannel.negotiatedks   +++rc|jS)zJ An ID number which uniquely identifies the data channel. r+r6s rrzRTCDataChannel.idrs yyrc.|jjS)zj A name describing the data channel. These labels are not required to be unique. )r,r r6s rr zRTCDataChannel.labelys  &&&rc.|jjS)zm Indicates whether or not the data channel guarantees in-order delivery of messages. )r,rr6s rrzRTCDataChannel.ordereds   (((rc.|jjS)z\ The maximum time in milliseconds during which transmissions are attempted. )r,r r6s rr z RTCDataChannel.maxPacketLifeTimes   222rc.|jjS)zL "The maximum number of retransmissions that are attempted. )r,rr6s rrzRTCDataChannel.maxRetransmitss   ///rc.|jjS)z5 The name of the subprotocol in use. )r,rr6s rrzRTCDataChannel.protocols   )))rc|jS)zY A string indicating the current state of the underlying data transport. )r-r6s r readyStatezRTCDataChannel.readyStates    rc|jS)zO The :class:`RTCSctpTransport` over which data is transmitted. )r.r6s rr zRTCDataChannel.transports rc:|jj|y)z) Close the data channel. N)r _data_channel_closer6s rclosezRTCDataChannel.closes **40rdatac|jdk7rtt|ttfst dt ||jj||y)zI Send `data` across the data channel to the remote peer. openz#Cannot send unsupported data type: N) rEr isinstancerbytesr0typer _data_channel_send)r3rJs rsendzRTCDataChannel.sendsO ??f $# #$e -B4:,OP P ))$5ramountc|j|jkDxr|j|z|jk}|xj|z c_|r|jdyy)Nbufferedamountlow)r)r9emit)r3rRcrosses_thresholds r_addBufferedAmountz!RTCDataChannel._addBufferedAmountsb  ! !D$C$C C R%%.$2Q2QQ  '  II) * rrc||_y)Nr>)r3rs r_setIdzRTCDataChannel._setIds  rstatec||jk7rc|jd|j|||_|dk(r|jdy|dk(r"|jd|jyyy)Nz - %s -> %srLclosedrI)r-_RTCDataChannel__log_debugrUremove_all_listeners)r3rZs r_setReadyStatezRTCDataChannel._setReadyStateso D%% %   \4+<+rqsW!",)   8 $  DkD(kD\/r