期望一个实现“Fn”特性的闭包,但这个闭包只实现了“FnOnce”
expected a closure that implements the `Fn` trait, but this closure only implements `FnOnce`
我想用 Hyper 实现一个网络服务。我从 the hello world example 复制了代码,它成功了。当我尝试将数据访问对象添加到 HelloWorld
结构时,出现错误,我不知道如何修复它。如何将特征成员添加到 Hyper 服务器?
extern crate futures;
extern crate hyper;
use futures::future::Future;
use hyper::header::ContentLength;
use hyper::server::{Http, Request, Response, Service};
trait Dao {}
struct MysqlDao;
impl Dao for MysqlDao {}
struct HelloWorld {
dao: Box<Dao>,
}
const PHRASE: &'static str = "Hello, World!";
impl Service for HelloWorld {
// boilerplate hooking up hyper's server types
type Request = Request;
type Response = Response;
type Error = hyper::Error;
// The future representing the eventual Response your call will
// resolve to. This can change to whatever Future you need.
type Future = Box<Future<Item = Self::Response, Error = Self::Error>>;
fn call(&self, _req: Request) -> Self::Future {
// We're currently ignoring the Request
// And returning an 'ok' Future, which means it's ready
// immediately, and build a Response with the 'PHRASE' body.
Box::new(futures::future::ok(
Response::new()
.with_header(ContentLength(PHRASE.len() as u64))
.with_body(PHRASE),
))
}
}
fn main() {
let addr = "127.0.0.1:3000".parse().unwrap();
let dao = Box::new(MysqlDao);
let server = Http::new().bind(&addr, || Ok(HelloWorld { dao })).unwrap();
server.run().unwrap();
}
错误信息:
error[E0525]: expected a closure that implements the `Fn` trait, but this closure only implements `FnOnce`
--> src/main.rs:44:42
|
44 | let server = Http::new().bind(&addr, || Ok(HelloWorld { dao })).unwrap();
| ---- ^^^^^^^^^^^^^^^^^^^^^^^^^
| |
| the requirement to implement `Fn` derives from here
|
note: closure is `FnOnce` because it moves the variable `dao` out of its environment
--> src/main.rs:44:61
|
44 | let server = Http::new().bind(&addr, || Ok(HelloWorld { dao })).unwrap();
| ^^^
我对 HelloWorld
结构进行了这些更改:
struct HelloWorld<'a> {
dao: &'a Dao,
}
我还将let server
语句更改为:
let server = Http::new()
.bind(&addr, move || Ok(HelloWorld { dao: &dao }))
.unwrap();
完整代码:
extern crate futures;
extern crate hyper;
use futures::future::Future;
use hyper::header::ContentLength;
use hyper::server::{Http, Request, Response, Service};
trait Dao {}
struct MysqlDao;
impl Dao for MysqlDao {}
struct HelloWorld<'a> {
dao: &'a Dao,
}
const PHRASE: &'static str = "Hello, World!";
impl<'a> Service for HelloWorld<'a> {
// boilerplate hooking up hyper's server types
type Request = Request;
type Response = Response;
type Error = hyper::Error;
// The future representing the eventual Response your call will
// resolve to. This can change to whatever Future you need.
type Future = Box<Future<Item = Self::Response, Error = Self::Error>>;
fn call(&self, _req: Request) -> Self::Future {
// We're currently ignoring the Request
// And returning an 'ok' Future, which means it's ready
// immediately, and build a Response with the 'PHRASE' body.
Box::new(futures::future::ok(
Response::new()
.with_header(ContentLength(PHRASE.len() as u64))
.with_body(PHRASE),
))
}
}
fn main() {
let addr = "127.0.0.1:3000".parse().unwrap();
let dao = MysqlDao;
let server = Http::new()
.bind(&addr, move || Ok(HelloWorld { dao: &dao }))
.unwrap();
server.run().unwrap();
}
我想用 Hyper 实现一个网络服务。我从 the hello world example 复制了代码,它成功了。当我尝试将数据访问对象添加到 HelloWorld
结构时,出现错误,我不知道如何修复它。如何将特征成员添加到 Hyper 服务器?
extern crate futures;
extern crate hyper;
use futures::future::Future;
use hyper::header::ContentLength;
use hyper::server::{Http, Request, Response, Service};
trait Dao {}
struct MysqlDao;
impl Dao for MysqlDao {}
struct HelloWorld {
dao: Box<Dao>,
}
const PHRASE: &'static str = "Hello, World!";
impl Service for HelloWorld {
// boilerplate hooking up hyper's server types
type Request = Request;
type Response = Response;
type Error = hyper::Error;
// The future representing the eventual Response your call will
// resolve to. This can change to whatever Future you need.
type Future = Box<Future<Item = Self::Response, Error = Self::Error>>;
fn call(&self, _req: Request) -> Self::Future {
// We're currently ignoring the Request
// And returning an 'ok' Future, which means it's ready
// immediately, and build a Response with the 'PHRASE' body.
Box::new(futures::future::ok(
Response::new()
.with_header(ContentLength(PHRASE.len() as u64))
.with_body(PHRASE),
))
}
}
fn main() {
let addr = "127.0.0.1:3000".parse().unwrap();
let dao = Box::new(MysqlDao);
let server = Http::new().bind(&addr, || Ok(HelloWorld { dao })).unwrap();
server.run().unwrap();
}
错误信息:
error[E0525]: expected a closure that implements the `Fn` trait, but this closure only implements `FnOnce`
--> src/main.rs:44:42
|
44 | let server = Http::new().bind(&addr, || Ok(HelloWorld { dao })).unwrap();
| ---- ^^^^^^^^^^^^^^^^^^^^^^^^^
| |
| the requirement to implement `Fn` derives from here
|
note: closure is `FnOnce` because it moves the variable `dao` out of its environment
--> src/main.rs:44:61
|
44 | let server = Http::new().bind(&addr, || Ok(HelloWorld { dao })).unwrap();
| ^^^
我对 HelloWorld
结构进行了这些更改:
struct HelloWorld<'a> {
dao: &'a Dao,
}
我还将let server
语句更改为:
let server = Http::new()
.bind(&addr, move || Ok(HelloWorld { dao: &dao }))
.unwrap();
完整代码:
extern crate futures;
extern crate hyper;
use futures::future::Future;
use hyper::header::ContentLength;
use hyper::server::{Http, Request, Response, Service};
trait Dao {}
struct MysqlDao;
impl Dao for MysqlDao {}
struct HelloWorld<'a> {
dao: &'a Dao,
}
const PHRASE: &'static str = "Hello, World!";
impl<'a> Service for HelloWorld<'a> {
// boilerplate hooking up hyper's server types
type Request = Request;
type Response = Response;
type Error = hyper::Error;
// The future representing the eventual Response your call will
// resolve to. This can change to whatever Future you need.
type Future = Box<Future<Item = Self::Response, Error = Self::Error>>;
fn call(&self, _req: Request) -> Self::Future {
// We're currently ignoring the Request
// And returning an 'ok' Future, which means it's ready
// immediately, and build a Response with the 'PHRASE' body.
Box::new(futures::future::ok(
Response::new()
.with_header(ContentLength(PHRASE.len() as u64))
.with_body(PHRASE),
))
}
}
fn main() {
let addr = "127.0.0.1:3000".parse().unwrap();
let dao = MysqlDao;
let server = Http::new()
.bind(&addr, move || Ok(HelloWorld { dao: &dao }))
.unwrap();
server.run().unwrap();
}