
    qi                     |    d dl mZmZ d dlmZmZmZ ddlmZ ddl	m
Z
  edeee
f         Z G d d	ee   e      Zy
)    )ABCabstractmethod)GenericTypeVarUnion   )
AudioFrame)
VideoFrameT)boundc                       e Zd Zeedefd              Zej                  ededdfd              Zdedededdfd	Z	d
ededdfdZ
ededefd       Zedd       Zy)FrameProcessorreturnc                      y N selfs    M/opt/pipecat/venv/lib/python3.12/site-packages/livekit/rtc/frame_processor.pyenabledzFrameProcessor.enabled   s    "    valueNc                      y r   r   )r   r   s     r   r   zFrameProcessor.enabled   s    ,/r   	room_nameparticipant_identitypublication_sidc                     y r   r   )r   r   r   r   s       r   _on_stream_info_updatedz&FrameProcessor._on_stream_info_updated   s     r   tokenurlc                     y r   r   )r   r   r    s      r   _on_credentials_updatedz&FrameProcessor._on_credentials_updated   s    r   framec                      y r   r   )r   r#   s     r   _processzFrameProcessor._process   s    '*r   c                      y r   r   r   s    r   _closezFrameProcessor._close    s    !r   )r   N)__name__
__module____qualname__propertyr   boolr   setterstrr   r"   r   r%   r'   r   r   r   r   r   
   s    ""  "^^/T/d/  /  "	
  
 LK#K$K*a*A* *! !r   r   N)abcr   r   typingr   r   r   audio_framer	   video_framer
   r   r   r   r   r   <module>r3      s>    # * * # # CuZ345"WQZ "r   