Added
-
Added
publish_async
method to jetstreamack_future = await js.publish_async("foo", b'bar') await ack_future
-
Added the ability to file contents as
user_credentials
(#546)
from nats.aio.client import RawCredentials
...
await nats.connect(user_credentials=RawCredentials("<creds file contents as string>"))
Fixed
- Fixed a race condition that could trigger error callbacks if a timeout and a response from a request where in-conflict (#573).