Refactor execution

Author: vinniefalco

include/boost/http/impl/parser.hpp

@@ -102,7 +102,7 @@ set_body(
 
     // Check ElasticBuffer type requirements
     static_assert(
-        capy::is_dynamic_buffer<ElasticBuffer>::value,
+        capy::is_DynamicBuffer<ElasticBuffer>::value,
         "Type requirements not met.");
 
     // body must not already be set
@@ -114,7 +114,7 @@ set_body(
         detail::throw_logic_error();
 
     auto& dyn = ws().emplace<
-        capy::any_dynamic_buffer_impl<typename
+        capy::any_DynamicBuffer_impl<typename
             std::decay<ElasticBuffer>::type,
                 buffers_N>>(std::forward<ElasticBuffer>(eb));
 
@@ -129,7 +129,7 @@ set_body(
 {
     // Check ElasticBuffer type requirements
     static_assert(
-        capy::is_dynamic_buffer<ElasticBuffer>::value,
+        capy::is_DynamicBuffer<ElasticBuffer>::value,
         "Type requirements not met.");
 
     // body must not already be set
@@ -142,7 +142,7 @@ set_body(
 
     // Use dynamic_buffer_ref to provide reference semantics
     auto& dyn = ws().emplace<
-        capy::any_dynamic_buffer_impl<
+        capy::any_DynamicBuffer_impl<
             detail::dynamic_buffer_ref<ElasticBuffer>,
             buffers_N>>(eb.get());
 

include/boost/http/impl/serializer.hpp

@@ -121,7 +121,7 @@ start(
     ConstBufferSequence&& cbs)
 {
     static_assert(
-        capy::const_buffer_sequence<ConstBufferSequence>,
+        capy::ConstBufferSequence<ConstBufferSequence>,
         "ConstBufferSequence type requirements not met");
 
     start_init(m);

include/boost/http/parser.hpp

@@ -642,7 +642,7 @@ class parser
 
     BOOST_HTTP_DECL
     void
-    set_body_impl(capy::any_dynamic_buffer&) noexcept;
+    set_body_impl(capy::any_DynamicBuffer&) noexcept;
 
     BOOST_HTTP_DECL
     void

include/boost/http/serializer.hpp

@@ -246,7 +246,7 @@ class serializer
 
         @par Constraints
         @code
-        capy::const_buffer_sequence<ConstBufferSequence>
+        capy::ConstBufferSequence<ConstBufferSequence>
         @endcode
 
         @par Exception Safety
@@ -275,7 +275,7 @@ class serializer
     template<
         class ConstBufferSequence,
         class = typename std::enable_if<
-            capy::const_buffer_sequence<ConstBufferSequence>>::type
+            capy::ConstBufferSequence<ConstBufferSequence>>::type
     >
     void
     start(

include/boost/http/server/route_handler.hpp

@@ -84,7 +84,7 @@ struct BOOST_HTTP_SYMBOL_VISIBLE
 
     /** Executor associated with the session.
     */
-    capy::any_dispatcher ex;
+    capy::any_executor_ref ex;
 
     /** Destructor
     */

include/boost/http/sink.hpp

@@ -108,7 +108,7 @@ struct BOOST_HTTP_SYMBOL_VISIBLE
         bool more)
     {
         static_assert(
-            capy::const_buffer_sequence<ConstBufferSequence>,
+            capy::ConstBufferSequence<ConstBufferSequence>,
             "Type requirements not met");
 
         return write_impl(bs, more);

include/boost/http/source.hpp

@@ -111,7 +111,7 @@ struct BOOST_HTTP_SYMBOL_VISIBLE
     read(MutableBufferSequence const& bs)
     {
         static_assert(
-            capy::mutable_buffer_sequence<MutableBufferSequence>,
+            capy::MutableBufferSequence<MutableBufferSequence>,
             "Type requirements not met");
 
         return read_impl(bs);

src/parser.cpp

@@ -554,7 +554,7 @@ class parser::impl
     capy::const_buffer_pair cbp_;
 
     detail::filter* filter_;
-    capy::any_dynamic_buffer* eb_;
+    capy::any_DynamicBuffer* eb_;
     sink* sink_;
 
     state state_;
@@ -1675,7 +1675,7 @@ class parser::impl
 
     void
     set_body(
-        capy::any_dynamic_buffer& eb) noexcept
+        capy::any_DynamicBuffer& eb) noexcept
     {
         eb_ = &eb;
         style_ = style::elastic;
@@ -2051,7 +2051,7 @@ is_body_set() const noexcept
 void
 parser::
 set_body_impl(
-    capy::any_dynamic_buffer& eb) noexcept
+    capy::any_DynamicBuffer& eb) noexcept
 {
     BOOST_ASSERT(impl_);
     impl_->set_body(eb);

src/server/route_handler.cpp

@@ -9,7 +9,7 @@
 
 #include <boost/http/server/route_handler.hpp>
 #include <boost/http/string_body.hpp>
-#include <boost/capy/ex/run_async.hpp>
+#include <boost/capy/ex/run_sync.hpp>
 
 namespace boost {
 namespace http {
@@ -56,19 +56,7 @@ spawn(
     capy::task<route_result> t) ->
         route_result
 {
-    return this->suspend(
-        [ex = this->ex, t = std::move(t)](resumer resume) mutable
-        {
-            capy::run_async(ex,
-                [resume](route_result rv)
-                {
-                    resume(rv);
-                },
-                [resume](std::exception_ptr ep)
-                {
-                    resume(ep);
-                })(std::move(t));
-        });
+    return capy::run_sync()(std::move(t));
 }
 
 } // http