Skip to content

Commit

Permalink
feat: migrate to async_nats client (#18165)
Browse files Browse the repository at this point in the history
* feat: migrate to `async_nats` client

* fix: port nats-integration-tests to async_nats

* Bump async-nats to v0.28

* Bump to latest git revision

* cargo vdev build licenses

* Use 0.31.0 for now

* bump client_capacity to 1024

* Replace std::thread::sleep with tokio::time::sleep

* Revert "bump client_capacity to 1024"

This reverts commit 365d10a.

* Flush the connection before finishing NatsSink

* Flush subscribe before proceeding with the test

* Fix NATS NKey auth

Port to async-nats was using NKey public key when calling `with_nkey`.
It should use the `seed`, which will be used to generate key pair.

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>

* Flush after every publish

* fmt

* downgrade time to 0.3.23

* cargo vdev build licenses

---------

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
Co-authored-by: Timur Makarchuk <timur.makarchuk@gmail.com>
Co-authored-by: Tomasz Pietrek <tomasz@nats.io>
  • Loading branch information
3 people authored Aug 11, 2023
1 parent f77fd3d commit 483e46f
Show file tree
Hide file tree
Showing 7 changed files with 155 additions and 245 deletions.
Loading

0 comments on commit 483e46f

Please sign in to comment.