Значение сообщения запроса должно быть допустимым для статического времени жизни

Я хочу реализовать функцию блокировки, которая отправляет запрос 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...

На данный момент у меня есть два вопроса:

  1. Какой компонент хочет msg быть действительным для статической жизни? Это не понятно мне из сообщения.
  2. Как я могу реализовать такую ​​функцию, не делая 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, так что вы не можете использовать его самостоятельно потом больше.

Другие вопросы по тегам