` z d dl mZ d dlmZmZ ed ee Zddl m
Z dgfd
d Z d S ) ) annotations)ListUnionpkgutil )Clientznats://localhost:4222serversUnion[str, List[str]]returnNATSc 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 optionsncs 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 r s # " " " " " :i , ,Xx @ @ & & & & & & 5L3L r