nats.rs

nats.rs copied to clipboard

- In `Client::request`, you get access to the message and can easily check the status of it so this is no longer an error. - The implicit handling is moved...

caspervonb

Jarema

Async-nats has significantly higher latency compared to blocking client or golang client

2

#### NATS version (`grep 'name = "nats"' Cargo.lock -A 1`) 0.17.0 #### rustc version (`rustc --version` - we support Rust 1.41 and up) 1.62.0 #### OS/Container environment: Arch Linux ####...

ilya-zlobintsev

Deny incompatible licenses in workflow

2

caspervonb

Enable using PushSubscription with crossbeam_channel::Select

7

0.17.0 refactored Jetstream interface and I don't see how I can use `crossbeam_channel::Select` with `PushSubscription`. In previous versions, the `Consumer` contained an optional `Subscription`, that exposed `crossbeam_channel::Receiver` https://docs.rs/nats/0.16.0/nats/jetstream/struct.Consumer.html. `Receiver` was...

marjakm

Work in progress. Needs agreement cros-org what is an idiomatic way to handle heartbeats.

Jarema

caspervonb

Jarema

caspervonb

Add Context::get_consumer_from_stream

1

Derek asked about a direct method to avoid one additional call to the server. Useful mostly when you get very few Consumers and latency is critical. Signed-off-by: Tomasz Pietrek

Jarema