1 use futures_util::future::ready; 2 use tower::util::service_fn; 3 use tower_service::Service; 4 5 #[tokio::test(flavor = "current_thread")] simple()6async fn simple() { 7 let _t = super::support::trace_init(); 8 9 let mut add_one = service_fn(|req| ready(Ok::<_, ()>(req + 1))); 10 let answer = add_one.call(1).await.unwrap(); 11 assert_eq!(answer, 2); 12 } 13