Значение сообщения запроса должно быть допустимым для статического времени жизни
Я хочу реализовать функцию блокировки, которая отправляет запрос POST с телом JSON и возвращает объект JSON ответа:
extern crate tokio_core;
extern crate rustc_serialize;
extern crate hyper;
extern crate futures;
use std::str;
use rustc_serialize::json;
use rustc_serialize::{Decoder, Decodable};
use hyper::{Method, Uri};
use hyper::client::{Client, Request};
use self::tokio_core::reactor::Core;
use self::futures::{Future, Stream};
#[derive(Debug, Clone)]
pub struct FooBar {
pub foo: String,
pub bar: String
}
impl Decodable for FooBar {
fn decode<D: Decoder>(d: &mut D) -> Result<Self, D::Error> {
d.read_struct("root", 0, |d| {
Ok(FooBar {
foo: try!(d.read_struct_field("foo", 0, |d| Decodable::decode(d))),
bar: try!(d.read_struct_field("bar", 1, |d| Decodable::decode(d)))
})
})
}
}
fn send_request(url: Uri, obj: json::Object) -> Option<FooBar> {
let mut core = Core::new().unwrap();
let client = Client::new(&core.handle());
let msg = json::encode(&obj).unwrap();
let mut request = Request::new(Method::Post, url);
request.set_body(msg.as_bytes());
let mut response = client.request(request).wait().unwrap();
assert_eq!(response.status(), hyper::Ok);
let res_vec = response.body().concat2().wait().unwrap().to_vec();
let res_str = str::from_utf8(&res_vec).unwrap();
return match json::decode(&res_str) {
Ok(res_obj) => Some(res_obj),
Err(err) => {
println!("{}", err);
None
}
}
}
Я получаю ошибку, что msg
не живет достаточно долго
error[E0597]: `msg` does not live long enough
--> src/test.rs:37:22
|
37 | request.set_body(msg.as_bytes());
| ^^^ does not live long enough
...
51 | }
| - borrowed value only lives until here
|
= note: borrowed value must be valid for the static lifetime...
На данный момент у меня есть два вопроса:
- Какой компонент хочет
msg
быть действительным для статической жизни? Это не понятно мне из сообщения. - Как я могу реализовать такую функцию, не делая
msg
действителен для статической жизни? В моем случае это не жизнеспособное решение.
зависимости:
rustc-serialize = "0.3"
futures = "0.1"
hyper = "0.11"
tokio-core = "0.1"
1 ответ
request.set_body()
принимает параметр, который должен быть преобразован в hyper::Body
(по умолчанию для B
в hyper::client::Request<B>
).
Если вы посмотрите на список From
("двойная" черта Into
) реализации для hyper::Body
вот увидишь impl From<&'static [u8]> for Body
- это то, где вы статические пожизненное требование приходит (нет impl<'a> From<&'a [u8]> for Body
это займет любую другую ссылку на "байты").
Но вы также увидите impl From<String> for Body
- так что должно быть хорошо просто пройти msg
(который должен быть String
насколько я могу судить) вместо msg.as_bytes()
в request.set_body()
, Это займет право собственности на строку msg
, так что вы не можете использовать его самостоятельно потом больше.