U
    k7g                     @   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)asyncioZTasksend_request).0r   r   r   r    3/tmp/pip-unpacked-wheel-vxwmpmkg/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 j}|j| |d4 I dH B}| I dH }t|}|W  5 Q I dH R  W  5 Q I dH R  S Q I dH R X W 5 Q I dH R X 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   