__ __ __ __ _____ _ _ _____ _ _ _
| \/ | \ \ / / | __ \ (_) | | / ____| | | | |
| \ / |_ __\ V / | |__) | __ ___ ____ _| |_ ___ | (___ | |__ ___| | |
| |\/| | '__|> < | ___/ '__| \ \ / / _` | __/ _ \ \___ \| '_ \ / _ \ | |
| | | | |_ / . \ | | | | | |\ V / (_| | || __/ ____) | | | | __/ | |
|_| |_|_(_)_/ \_\ |_| |_| |_| \_/ \__,_|\__\___| |_____/|_| |_|\___V 2.1
if you need WebShell for Seo everyday contact me on Telegram
Telegram Address : @jackleet
For_More_Tools:
�
�`���� �� �z � d dl mZ d dlmZmZ ed� � � ee� � Zddl m
Z dgfd
d �Z d S )� )� annotations)�List�Union�pkgutil� )�Clientznats://localhost:4222�servers�Union[str, List[str]]�return�NATSc � �N K � t � � } |j | fi |��� d{V �� |S )a�
:param servers: List of servers to connect.
:param options: NATS connect options.
::
import asyncio
import nats
async def main():
# Connect to NATS Server.
nc = await nats.connect('demo.nats.io')
await nc.publish('foo', b'Hello World!')
await nc.flush()
await nc.close()
if __name__ == '__main__':
asyncio.run(main())
N)r �connect)r �options�ncs �m/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/nats/__init__.pyr r sB � � � �*
���B�
�"�*�W�
(�
(��
(�
(�(�(�(�(�(�(�(�
�I� N)r r
r r )
�
__future__r �typingr r �
__import__� extend_path�__path__�__name__�
aio.clientr r r � r r �<module>r s� �� #� "� "� "� "� "� � � � � � � � � �:�i� � � ,� ,�X�x� @� @�� &� &� &� &� &� &� 5L�3L� � � � � � � r