prep release

.github/workflows/windows.yml

@@ -73,3 +73,4 @@ jobs:
                 --skip test_connection_wait_queue_force_close
                 --skip test_params
                 --skip test_body
+                --skip test_form

ntex/CHANGES.md

@@ -1,6 +1,12 @@
 # Changes
 
-* Allow to wake up write io task
+## [0.2.0-b.10] - 2021-01-28
+
+* framed: Allow to wake up write io task
+
+* framed: Prevent uneeded read task wakeups
+
+* framed: Cleanup State impl
 
 ## [0.2.0-b.7] - 2021-01-25
 

ntex/Cargo.toml

@@ -51,7 +51,7 @@ derive_more = "0.99.11"
 either = "1.6.1"
 encoding_rs = "0.8.26"
 futures = "0.3.12"
-ahash = "0.6.3"
+ahash = "0.7.0"
 h2 = "0.2.4"
 http = "0.2.1"
 httparse = "1.3"
@@ -97,7 +97,6 @@ brotli2 = { version="0.3.2", optional = true }
 flate2 = { version = "1.0.14", optional = true }
 
 [dev-dependencies]
-futures = "0.3.12"
 env_logger = "0.8"
 serde_derive = "1.0"
 open-ssl = { version="0.10", package = "openssl" }

ntex/src/framed/state.rs

@@ -349,7 +349,18 @@ impl State {
     #[inline]
     /// Wake write io task
     pub fn dsp_restart_write_task(&self) {
-        self.0.write_task.wake();
+        // if write buffer is empty then write task is asleep
+        // otherwise write task is active
+        if self.0.write_buf.borrow().is_empty() {
+            self.0.write_task.wake();
+        }
+    }
+
+    #[doc(hidden)]
+    #[inline]
+    /// Wake write io task
+    pub fn dsp_flush_write_data(&self, _: &Waker) {
+        self.dsp_restart_write_task()
     }
 
     #[inline]