|
17 | 17 | #include<boost/network/protocol/http/parser/incremental.hpp> |
18 | 18 | #include<boost/network/protocol/http/request_parser.hpp> |
19 | 19 | #include<boost/network/traits/string.hpp> |
| 20 | +#include<boost/thread/future.hpp> |
20 | 21 |
|
21 | 22 | namespaceboost { |
22 | 23 | namespacenetwork { |
@@ -57,30 +58,30 @@ struct http_async_protocol_handler { |
57 | 58 | // TODO(dberris): review parameter necessity. |
58 | 59 | (void)get_body; |
59 | 60 |
|
60 | | -std::shared_future<string_type>source_future( |
| 61 | +boost::shared_future<string_type>source_future( |
61 | 62 | source_promise.get_future()); |
62 | 63 | source(response_, source_future); |
63 | 64 |
|
64 | | -std::shared_future<string_type>destination_future( |
| 65 | +boost::shared_future<string_type>destination_future( |
65 | 66 | destination_promise.get_future()); |
66 | 67 | destination(response_, destination_future); |
67 | 68 |
|
68 | | -std::shared_future<typename headers_container<Tag>::type>headers_future( |
| 69 | +boost::shared_future<typename headers_container<Tag>::type>headers_future( |
69 | 70 | headers_promise.get_future()); |
70 | 71 | headers(response_, headers_future); |
71 | 72 |
|
72 | | -std::shared_future<string_type>body_future(body_promise.get_future()); |
| 73 | +boost::shared_future<string_type>body_future(body_promise.get_future()); |
73 | 74 | body(response_, body_future); |
74 | 75 |
|
75 | | -std::shared_future<string_type>version_future( |
| 76 | +boost::shared_future<string_type>version_future( |
76 | 77 | version_promise.get_future()); |
77 | 78 | version(response_, version_future); |
78 | 79 |
|
79 | | -std::shared_future<std::uint16_t>status_future( |
| 80 | +boost::shared_future<std::uint16_t>status_future( |
80 | 81 | status_promise.get_future()); |
81 | 82 | status(response_, status_future); |
82 | 83 |
|
83 | | -std::shared_future<string_type>status_message_future( |
| 84 | +boost::shared_future<string_type>status_message_future( |
84 | 85 | status_message_promise.get_future()); |
85 | 86 | status_message(response_, status_message_future); |
86 | 87 | } |
@@ -339,13 +340,13 @@ struct http_async_protocol_handler { |
339 | 340 | typedef std::array<typename char_<Tag>::type,1024> buffer_type; |
340 | 341 |
|
341 | 342 | response_parser_type response_parser_; |
342 | | -std::promise<string_type> version_promise; |
343 | | -std::promise<std::uint16_t> status_promise; |
344 | | -std::promise<string_type> status_message_promise; |
345 | | -std::promise<typename headers_container<Tag>::type> headers_promise; |
346 | | -std::promise<string_type> source_promise; |
347 | | -std::promise<string_type> destination_promise; |
348 | | -std::promise<string_type> body_promise; |
| 343 | +boost::promise<string_type> version_promise; |
| 344 | +boost::promise<std::uint16_t> status_promise; |
| 345 | +boost::promise<string_type> status_message_promise; |
| 346 | +boost::promise<typename headers_container<Tag>::type> headers_promise; |
| 347 | +boost::promise<string_type> source_promise; |
| 348 | +boost::promise<string_type> destination_promise; |
| 349 | +boost::promise<string_type> body_promise; |
349 | 350 | buffer_type part; |
350 | 351 | typename buffer_type::const_iterator part_begin; |
351 | 352 | string_type partial_parsed; |
|