mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-06 22:37:39 +03:00
Code Issues Projects Releases Packages Wiki Activity

update tests

Browse source
This commit is contained in:
Nikolay Kim 2021-04-04 01:24:44 +06:00
parent 91ee6762e7
commit 7b0a74fc61
4 changed files with 11 additions and 77 deletions
Download patch file Download diff file Expand all files Collapse all files

74
ntex-util/CHANGES.md
View file

@ -1,75 +1,5 @@
# Changes
## [0.4.1] - 2021-04-04
## [0.1.0] - 2021-04-04
* Use Either from ntex-service
## [0.4.0] - 2021-02-23
* Migrate to tokio 1.x
## [0.3.0] - 2021-02-20
* Make Encoder and Decoder methods immutable
## [0.2.2] - 2021-01-21
* Flush underlying io stream
## [0.2.1] - 2020-08-10
* Require `Debug` impl for `Error`
## [0.2.0] - 2020-08-10
* Include custom `Encoder` and `Decoder` traits
* Remove `From<io::Error>` constraint from `Encoder` and `Decoder` traits
## [0.1.2] - 2020-04-17
* Do not swallow unprocessed data on read errors
## [0.1.1] - 2020-04-07
* Optimize io operations
* Fix framed close method
## [0.1.0] - 2020-03-31
* Fork crate to ntex namespace
* Use `.advance()` intead of `.split_to()`
* Add Unpin constraint and remove unneeded unsafe
## [0.2.0] - 2019-12-10
* Use specific futures dependencies
## [0.2.0-alpha.4]
* Fix buffer remaining capacity calcualtion
## [0.2.0-alpha.3]
* Use tokio 0.2
* Fix low/high watermark for write/read buffers
## [0.2.0-alpha.2]
* Migrated to `std::future`
## [0.1.2] - 2019-03-27
* Added `Framed::map_io()` method.
## [0.1.1] - 2019-03-06
* Added `FramedParts::with_read_buffer()` method.
## [0.1.0] - 2018-12-09
* Move codec to separate crate
* Move utils to separate crate

6
ntex-util/src/channel/condition.rs
View file

@ -97,7 +97,7 @@ impl Drop for Waiter {
#[cfg(test)]
mod tests {
use super::*;
use crate::util::lazy;
use crate::future::lazy;
#[ntex::test]
#[allow(clippy::unit_cmp)]
@ -135,6 +135,10 @@ mod tests {
cond.notify();
assert_eq!(lazy(|cx| waiter.poll_ready(cx)).await, Poll::Ready(()));
let waiter2 = waiter.clone();
assert_eq!(lazy(|cx| waiter.poll_ready(cx)).await, Poll::Pending);
assert_eq!(lazy(|cx| waiter2.poll_ready(cx)).await, Poll::Pending);
drop(cond);
assert_eq!(lazy(|cx| waiter.poll_ready(cx)).await, Poll::Ready(()));
assert_eq!(lazy(|cx| waiter2.poll_ready(cx)).await, Poll::Ready(()));

4
ntex-util/src/channel/oneshot.rs
View file

@ -101,9 +101,9 @@ impl<T> Future for Receiver<T> {
#[cfg(test)]
mod tests {
use super::*;
use crate::util::lazy;
use crate::future::lazy;
#[crate::rt_test]
#[ntex::test]
async fn test_oneshot() {
let (tx, rx) = channel();
tx.send("test").unwrap();

4
ntex-util/src/channel/pool.rs
View file

@ -175,9 +175,9 @@ impl<T> Future for Receiver<T> {
#[cfg(test)]
mod tests {
use super::*;
use crate::util::lazy;
use crate::future::lazy;
#[crate::rt_test]
#[ntex::test]
async fn test_pool() {
let p = new();
let (tx, rx) = p.channel();