o
    Qh}                     @   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__ U/home/air/yokohama/back/venv/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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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
   