Merge pull request #3 from melekes/anton/set-watermark

framed/: Add `send_high_water_mark` and `set_send_high_water_mark`

CHANGELOG.md

@@ -6,6 +6,14 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic
 Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.6.1] - 2022-11-08
+
+### Added
+
+- `Framed::send_high_water_mark` and `Framed::set_send_high_water_mark` [#3].
+
+[#3]: https://github.com/mxinden/asynchronous-codec/pull/3
+
 ## [0.6.0] - 2021-02-01
 
 ### Changed

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "asynchronous-codec"
 edition = "2018"
-version = "0.6.0"
+version = "0.6.1"
 authors = ["Max Inden <[email protected]>"]
 description = "Utilities for encoding and decoding frames using `async/await`"
 license = "MIT"

src/framed.rs

@@ -135,6 +135,20 @@ where
     pub fn read_buffer(&self) -> &BytesMut {
         self.inner.buffer()
     }
+
+    /// High-water mark for writes, in bytes
+    ///
+    /// See [`FramedWrite::send_high_water_mark`].
+    pub fn send_high_water_mark(&self) -> usize {
+        self.inner.high_water_mark
+    }
+
+    /// Sets high-water mark for writes, in bytes
+    ///
+    /// See [`FramedWrite::set_send_high_water_mark`].
+    pub fn set_send_high_water_mark(&mut self, hwm: usize) {
+        self.inner.high_water_mark = hwm;
+    }
 }
 
 impl<T, U> Stream for Framed<T, U>