Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
0.31.0
This release focuses on improvements of heartbeats in JetStream Consumers.
Heartbeats are a tool that tells the user if the given consumer is healthy but does not get any messages or if the reason for no message is an actual problem.
However, if the user was not polling the
Stream
future for the next messages for a long time (because it was slowly processing messages), that could trigger idle heartbeats, as the library could not see the heartbeat messages without messages being polled.This release fixes it by starting the idle heartbeat timer only after Stream future is polled (which usually means calling
messages.next().await
).What's Changed
HeaderName::from_str
call by @caspervonb in Fix unwrap fromHeaderName::from_str
call #1032Option
and accessing innerT
by @paolobarbolini in Use idiomatic method for writingOption
and accessing innerT
#1034BatchConfig
expiration
by @paolobarbolini in Fix millis -> nanos typo inBatchConfig
expiration
#1037Full Changelog: async-nats/v0.30.0...async-nats/v0.30.1
Signed-off-by: Tomasz Pietrek tomasz@nats.io