o di@sxddlZddlmZddlmZmZddlmZddlm Z e e Z eGdddZ Gd d d eZdd lmZdS) N) dataclass)OptionalUnion)AsyncIOEventEmitter)InvalidStateErrorc@s~eZdZUdZdZeed< dZee ed< dZ ee ed< dZ e ed< dZ eed < d Ze ed < dZee ed <dS) RTCDataChannelParameterszy The :class:`RTCDataChannelParameters` dictionary describes the configuration of an :class:`RTCDataChannel`. labelNmaxPacketLifeTimemaxRetransmitsTorderedprotocolF negotiatedid)__name__ __module__ __qualname____doc__r str__annotations__r rintr r boolrrrrrI/home/ubuntu/.local/lib/python3.10/site-packages/aiortc/rtcdatachannel.pyr s     rc seZdZdZ d5dddededdffd d Zedefd d Z edefd dZ e j deddfddZ edefddZ ede efddZedefddZedefddZede efddZede efddZedefddZedefdd Zed6d!d"Zd7d#d$Zd%eeefddfd&d'Zd(eddfd)d*Zd+eddfd,d-Zd.eddfd/d0Zd1ed2eddfd3d4ZZ S)8RTCDataChannela 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`. T transportRTCSctpTransport parameters send_openreturnNcstd|_d|_|j|_||_d|_||_||_ |jj r2|jdus.|jdks.|jdkr2t d|jj sF|j rDd|_ |j |dSdS|j |dS)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)selfrrr __class__rrr#8s& zRTCDataChannel.__init__cC|jS)z` The number of bytes of data currently queued to be sent over the data channel. )r$r.rrrbufferedAmountUzRTCDataChannel.bufferedAmountcCr1)zY The number of bytes of buffered outgoing data that is considered "low". )r%r2rrrbufferedAmountLowThreshold\r4z)RTCDataChannel.bufferedAmountLowThresholdvaluecCs"|dks|dkr td||_dS)Nrlz:bufferedAmountLowThreshold must be in range 0 - 4294967295)r+r%)r.r6rrrr5cs  cC|jjS)zB Whether data channel was negotiated out-of-band. )r'rr2rrrrkzRTCDataChannel.negotiatedcCr1)zJ An ID number which uniquely identifies the data channel. r&r2rrrrrr4zRTCDataChannel.idcCr7)zj A name describing the data channel. These labels are not required to be unique. )r'r r2rrrr yszRTCDataChannel.labelcCr7)zm Indicates whether or not the data channel guarantees in-order delivery of messages. )r'r r2rrrr szRTCDataChannel.orderedcCr7)z\ The maximum time in milliseconds during which transmissions are attempted. )r'r r2rrrr r8z RTCDataChannel.maxPacketLifeTimecCr7)zL "The maximum number of retransmissions that are attempted. )r'r r2rrrr r8zRTCDataChannel.maxRetransmitscCr7)z5 The name of the subprotocol in use. )r'rr2rrrrr8zRTCDataChannel.protocolcCr1)zY A string indicating the current state of the underlying data transport. )r(r2rrr readyStater4zRTCDataChannel.readyStatecCr1)zO The :class:`RTCSctpTransport` over which data is transmitted. )r)r2rrrrr4zRTCDataChannel.transportcCs|j|dS)z) Close the data channel. N)r_data_channel_closer2rrrcloseszRTCDataChannel.closedatacCs@|jdkrtt|ttfstdt||j||dS)zI Send `data` across the data channel to the remote peer. openz#Cannot send unsupported data type: N) r:r isinstancerbytesr+typer_data_channel_send)r.r=rrrsends zRTCDataChannel.sendamountcCs@|j|jko |j||jk}|j|7_|r|ddSdS)Nbufferedamountlow)r$r5emit)r.rDcrosses_thresholdrrr_addBufferedAmounts z!RTCDataChannel._addBufferedAmountrcCs ||_dS)Nr9)r.rrrr_setIds zRTCDataChannel._setIdstatecCs\||jkr*|d|j|||_|dkr|ddS|dkr,|d|dSdSdS)Nz - %s -> %sr>closedr<)r(_RTCDataChannel__log_debugrFremove_all_listeners)r.rJrrr_setReadyStates   zRTCDataChannel._setReadyStatemsgargscGs tjd||jg|RdS)NzRTCDataChannel(%s) )loggerdebugr&)r.rOrPrrr __log_debugs zRTCDataChannel.__log_debug)T)r r)r N)!rrrrrrr#propertyrr3r5setterrrrrr r r r rr:rr<rr@rCrHrIrNobjectrL __classcell__rrr/rr/sT     r)r)logging dataclassesrtypingrr pyee.asyncior exceptionsr getLoggerrrQrrrtcsctptransportrrrrrs    "/