Skip to content

Commit

Permalink
Prep release
Browse files Browse the repository at this point in the history
  • Loading branch information
fafhrd91 committed Nov 12, 2023
1 parent 1420c8c commit 3f628a3
Show file tree
Hide file tree
Showing 3 changed files with 15 additions and 2 deletions.
2 changes: 1 addition & 1 deletion CHANGES.md
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
# Changes

## [0.8.5] - 2023-11-11
## [0.8.5] - 2023-11-12

* Update io

Expand Down
2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ uuid = { version = "1", features = ["v4"] }

[dev-dependencies]
env_logger = "0.10"
ntex = { version = "0.7.9", features = ["tokio"] }
ntex = { version = "0.7", features = ["tokio"] }

[patch.crates-io]
ntex-amqp = { path = "." }
Expand Down
13 changes: 13 additions & 0 deletions src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -154,6 +154,19 @@ impl Configuration {
self
}

/// Set read rate parameters for single frame.
///
/// Set max timeout for reading single frame. If the client
/// sends `rate` amount of data, increase the timeout by 1 second for every.
/// But no more than `max_timeout` timeout.
///
/// By default frame read rate is disabled.
pub fn frame_read_rate(self, timeout: Seconds, max_timeout: Seconds, rate: u16) -> Self {
self.disp_config
.set_frame_read_rate(timeout, max_timeout, rate);
self
}

/// Create `Open` performative for this configuration.
pub fn to_open(&self) -> Open {
Open(Box::new(OpenInner {
Expand Down

0 comments on commit 3f628a3

Please sign in to comment.