我有一个简单的休息类型的皮肤围绕一个大型文本文件,我需要交互式查询.它可能涉及繁重的计算,所以我使用了锈.我用铁做了一个简单的宁静皮肤.请注意,我没有做过很多生锈.这只是在localhost上运行.
pub fn query<'a>(parsed: &'a Parsed, context:&Context) -> {
// parsed.keys is a hash containing config informtion
// context is what I query
let local_port = format!("{}:{}", "localhost", parsed.keys[AS_SERVER]);
fn test_connect<'a>(r: &'a mut Request, c:&'a Context) -> IronResult<Response> {
let url = r.url.to_string();
let result = // some logic
Ok(Response::with((status::Ok, format!("requested=\"{}:{}\"\n", url, result))))
}
let mut router = Router::new();
router.get("*", move |r: &mut Request| test_connect(r, &context));
let connection_status = Iron::new(router).http(&local_port[..]);
connection_status.ok().expect("could not connect");
}
现在我的问题是我如何让控件退出监听循环
Iron::new(router).http(&local_port[..]);
我只想说curl http:// localhost / done
并有listen函数退出,所以一些日志记录和继续前进.这可能吗?我已经尝试过恐慌,但即使这样也不会退出监听循环?
我尝试返回像Err(IronError :: new(StringError(url),status :: ServiceUnavailable))
那个状态:: ServiceUnavailable只是随机的东西 – 它需要一些东西:我知道它在语义上不正确,不知道要使用什么.但是错误没有任何处理程序,因此它会默默地消失.
我想我会用aftermiddleware设置一些东西,但我不知道是什么?
最佳答案 一种方法是在处理程序和启动服务器的线程之间设置消息.发送消息时,主线程可以调用
Listening::close
在这个例子中,我使用了Condvar
.我希望你也可以使用一个频道,但是无法快速复制和粘贴示例频道并使其正常工作…… ^ _ ^
extern crate iron;
use iron::prelude::*;
use iron::status;
use std::sync::{Arc, Mutex, Condvar};
fn main() {
// Copied from docs
let pair = Arc::new((Mutex::new(false), Condvar::new()));
let pair2 = pair.clone();
let handler = move |_: &mut Request| {
// Copied from docs
let &(ref lock, ref cvar) = &*pair2;
let mut should_exit = lock.lock().unwrap();
*should_exit = true;
cvar.notify_one();
Ok(Response::with((status::Ok, "Hello World!")))
};
// Hold onto the listener
let mut serv = Iron::new(handler).http("localhost:3210").unwrap();
println!("Now listening...");
// Copied from docs
let &(ref lock, ref cvar) = &*pair;
let mut should_exit = lock.lock().unwrap();
while !*should_exit {
should_exit = cvar.wait(should_exit).unwrap();
}
serv.close().unwrap();
println!("Exiting...");
}