U
    ™ƒ0a`  ã                   @   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   © úo/var/www/html/staging.mfahmagazine.net/magazine_api/magazine_env/lib/python3.8/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 š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   ZsessionÚresÚresultr   r   r   r      s    	
r   )r   )r   r   r   r   r   r   r   r   r   Ú<module>   s   