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

More tests (#368)

Browse source
This commit is contained in:
Nikolay Kim 2024-05-29 20:30:14 +05:00 • committed by GitHub
parent 34142e1ae2
commit e0b5284fdd
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
9 changed files with 82 additions and 37 deletions
Download patch file Download diff file Expand all files Collapse all files

18
ntex-service/src/and_then.rs
View file

@ -141,10 +141,12 @@ mod tests {
async fn test_ready() {
let cnt = Rc::new(Cell::new(0));
let cnt_sht = Rc::new(Cell::new(0));
let srv = chain(Srv1(cnt.clone(), cnt_sht.clone()))
.and_then(Srv2(cnt.clone(), cnt_sht.clone()))
.clone()
.into_pipeline();
let srv = Box::new(
chain(Srv1(cnt.clone(), cnt_sht.clone()))
.and_then(Srv2(cnt.clone(), cnt_sht.clone()))
.clone(),
)
.into_pipeline();
let res = srv.ready().await;
assert_eq!(res, Ok(()));
assert_eq!(cnt.get(), 2);
@ -168,9 +170,11 @@ mod tests {
#[ntex::test]
async fn test_call() {
let cnt = Rc::new(Cell::new(0));
let srv = chain(Srv1(cnt.clone(), Rc::new(Cell::new(0))))
.and_then(Srv2(cnt, Rc::new(Cell::new(0))))
.into_pipeline();
let srv = Box::new(
chain(Srv1(cnt.clone(), Rc::new(Cell::new(0))))
.and_then(Srv2(cnt, Rc::new(Cell::new(0)))),
)
.into_pipeline();
let res = srv.call("srv1").await;
assert!(res.is_ok());
assert_eq!(res.unwrap(), ("srv1", "srv2"));

14
ntex-service/src/fn_service.rs
View file

@ -369,20 +369,6 @@ where
}
}
impl<F, S, R, Req, E, C> IntoServiceFactory<FnServiceNoConfig<F, S, R, Req, E>, Req, C>
for F
where
F: Fn() -> R,
R: Future<Output = Result<S, E>>,
S: Service<Req>,
C: 'static,
{
#[inline]
fn into_factory(self) -> FnServiceNoConfig<F, S, R, Req, E> {
FnServiceNoConfig::new(self)
}
}
#[cfg(test)]
mod tests {
use ntex_util::future::lazy;