o
    ¼>hÈ  ã                   @   sž   d dl Z d dlmZ eƒ ZG dd„ deƒZdd„ Zdd„ Zd	d
„ Zdd„ Z	dd„ Z
dd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd „ ZdS )!é    N)Úimport_numpyc                   @   s^   e Zd ZdgZeddd„ƒZeddd„ƒZdd„ Zd	d
„ Zdd„ Z	dd„ Z
dd„ Zdd„ ZdS )Ú	SubscribeÚ_tabr   c                 C   s.   t j t jj||¡}tƒ }| ||| ¡ |S ©N)ÚflatbuffersÚencodeÚGetÚpackerÚuoffsetr   ÚInit)ÚclsÚbufÚoffsetÚnÚx© r   ú†/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/wamp/gen/wamp/proto/Subscribe.pyÚ	GetRootAs   s   zSubscribe.GetRootAsc                 C   s   |   ||¡S )z6This method is deprecated. Please switch to GetRootAs.)r   )r   r   r   r   r   r   ÚGetRootAsSubscribe   s   zSubscribe.GetRootAsSubscribec                 C   s   t j ||¡| _d S r   )r   ÚtableÚTabler   )Úselfr   Úposr   r   r   r      s   zSubscribe.Initc                 C   ó<   t jj | j d¡¡}|dkr| j t jj|| jj ¡S dS ©Né   r   ©	r   Únumber_typesÚUOffsetTFlagsÚpy_typer   ÚOffsetr   ÚUint64FlagsÚPos©r   Úor   r   r   ÚSession   ó   zSubscribe.Sessionc                 C   r   )Né   r   r   r#   r   r   r   ÚRequest#   r&   zSubscribe.Requestc                 C   s6   t jj | j d¡¡}|dkr| j || jj ¡S d S )Né   r   )r   r   r   r   r   r    ÚStringr"   r#   r   r   r   ÚTopic*   s   zSubscribe.Topicc                 C   r   )Né
   r   )	r   r   r   r   r   r    r   Ú
Uint8Flagsr"   r#   r   r   r   ÚMatch1   r&   zSubscribe.Matchc                 C   s@   t jj | j d¡¡}|dkrt| j t jj|| jj	 ¡ƒS dS )Né   r   F)
r   r   r   r   r   r    Úboolr   Ú	BoolFlagsr"   r#   r   r   r   ÚGetRetained8   s   zSubscribe.GetRetainedN)r   )Ú__name__Ú
__module__Ú__qualname__Ú	__slots__Úclassmethodr   r   r   r%   r(   r+   r.   r2   r   r   r   r   r   	   s    r   c                 C   s   |   d¡ d S )Né   )ÚStartObject©Úbuilderr   r   r   ÚSubscribeStart>   s    r<   c                 C   ó   t | ƒS r   )r<   r:   r   r   r   ÚStart?   ó   r>   c                 C   s   |   d|d¡ d S )Nr   ©ÚPrependUint64Slot©r;   Úsessionr   r   r   ÚSubscribeAddSessionA   ó    rD   c                 C   ó
   t | |ƒS r   )rD   rB   r   r   r   Ú
AddSessionB   ó   
rG   c                 C   ó   |   d|d¡ d S )Né   r   r@   ©r;   Úrequestr   r   r   ÚSubscribeAddRequestD   rE   rM   c                 C   rF   r   )rM   rK   r   r   r   Ú
AddRequestE   rH   rN   c                 C   s   |   dtjj |¡d¡ d S )Né   r   )ÚPrependUOffsetTRelativeSlotr   r   r   r   ©r;   Útopicr   r   r   ÚSubscribeAddTopicG   s    rS   c                 C   rF   r   )rS   rQ   r   r   r   ÚAddTopicH   rH   rT   c                 C   rI   )Né   r   )ÚPrependUint8Slot©r;   Úmatchr   r   r   ÚSubscribeAddMatchJ   rE   rY   c                 C   rF   r   )rY   rW   r   r   r   ÚAddMatchK   rH   rZ   c                 C   rI   r   )ÚPrependBoolSlot©r;   ÚgetRetainedr   r   r   ÚSubscribeAddGetRetainedM   rE   r^   c                 C   rF   r   )r^   r\   r   r   r   ÚAddGetRetainedN   rH   r_   c                 C   s   |   ¡ S r   )Ú	EndObjectr:   r   r   r   ÚSubscribeEndP   s    ra   c                 C   r=   r   )ra   r:   r   r   r   ÚEndQ   r?   rb   )r   Úflatbuffers.compatr   ÚnpÚobjectr   r<   r>   rD   rG   rM   rN   rS   rT   rY   rZ   r^   r_   ra   rb   r   r   r   r   Ú<module>   s$   5