o
    %h                     @   sD   d dl Z d dlmZ d dlmZmZ d dlmZ G dd deZdS )    N)Path)DictUnion)ChannelOwnerc                
       sZ   e Zd Zdededededdf
 fddZd	eeef ddfd
dZ	de
fddZ  ZS )StreamparenttypeguidinitializerreturnNc                    s   t  |||| d S N)super__init__)selfr   r   r	   r
   	__class__ L/var/www/html/myenv/lib/python3.10/site-packages/playwright/_impl/_stream.pyr      s   zStream.__init__pathc                    s   | j d fddI d H 	 | jdd ddiI d H   s n| j d  fddI d H  q| j d fddI d H  d S )	Nc                      s
   t  dS )Nwb)openr   )r   r   r   <lambda>   s   
 z Stream.save_as.<locals>.<lambda>Treadsize   c                      s    t S r   )writebase64	b64decoder   )binaryfiler   r   r   #   s    c                      s      S r   )closer   )r   r   r   r   %   s    )_looprun_in_executor_channelsend)r   r   r   )r   r   r   r   save_as   s   
 zStream.save_asc                    s<   d}	 | j dd ddiI d H }|s	 |S |t|7 }q)N    Tr   r   r   )r#   r$   r   r   )r   r   chunkr   r   r   read_all'   s   zStream.read_all)__name__
__module____qualname__r   strr   r   r   r   r%   bytesr(   __classcell__r   r   r   r   r      s    r   )	r   pathlibr   typingr   r   playwright._impl._connectionr   r   r   r   r   r   <module>   s
   