o
    h`                     @   s.   d dl Z d dlZd dlZdd ZdddZdS )    Nc                    s(    fdd|D }t j| I dH S )

    :param end_point (str) : FCM endpoint
    :param headers (dict) : FCM Request Headers
    :param payloads (list) : payloads contains bytes after self.parse_payload
    :param timeout (int) : FCM timeout
    :return:
    c              
      s"   g | ]}t t |d qS ))	end_pointheaderspayloadtimeout)asyncioTasksend_request).0r   r   r   r    W/var/www/html/magazine_api/magazine_env/lib/python3.10/site-packages/pyfcm/async_fcm.py
<listcomp>   s   " zfetch_tasks.<locals>.<listcomp>N)r   Zgather)r   r   Zpayloadsr   Zfetchesr   r   r   fetch_tasks   s   	r      c              
      s   t j|d}t j||d4 I dH E}|j| |d4 I dH #}| I dH }t|}|W  d  I dH  W  d  I dH  S 1 I dH sGw   Y  W d  I dH  dS 1 I dH s]w   Y  dS )r   )total)r   r   N)data)aiohttpZClientTimeoutZClientSessionposttextjsonloads)r   r   r   r   sessionresresultr   r   r   r	      s   	
.r	   )r   )r   r   r   r   r	   r   r   r   r   <module>   s
    