Fix route_params::spawn to use capy::executor::post

Author: vinniefalco

include/boost/http_proto/server/route_handler.hpp

@@ -13,6 +13,7 @@
 #include <boost/http_proto/detail/config.hpp>
 #include <boost/http_proto/server/router_types.hpp>
 #include <boost/capy/datastore.hpp>
+#include <boost/capy/executor.hpp>
 #include <boost/capy/task.hpp>
 #include <boost/http_proto/request.hpp>  // VFALCO forward declare?
 #include <boost/http_proto/request_parser.hpp>  // VFALCO forward declare?
@@ -81,6 +82,10 @@ struct BOOST_HTTP_PROTO_SYMBOL_VISIBLE
     */
     suspender suspend;
 
+    /** Executor associated with the session.
+    */
+    capy::executor ex;
+
     /** Destructor
     */
     BOOST_HTTP_PROTO_DECL
@@ -176,7 +181,7 @@ struct BOOST_HTTP_PROTO_SYMBOL_VISIBLE
             from the route handler.
     */
     BOOST_HTTP_PROTO_DECL
-    virtual auto spawn(
+    auto spawn(
         capy::task<route_result> coro) ->
             route_result;
 

src/server/route_handler.cpp

@@ -56,10 +56,30 @@ set_body(std::string s)
 auto
 route_params::
 spawn(
-    capy::task<route_result>) ->
+    capy::task<route_result> t) ->
         route_result
 {
-    detail::throw_invalid_argument();
+    return this->suspend(
+        [ex = this->ex, t = std::move(t)](resumer resume) mutable
+        {
+            auto h = t.release();
+
+            h.promise().on_done = [resume, h]()
+            {
+                auto& r = h.promise().result;
+                if(r.index() == 2)
+                {
+                    auto ep = std::get<2>(r);
+                    h.destroy();
+                    std::rethrow_exception(ep);
+                }
+                auto rv = std::move(std::get<1>(r));
+                h.destroy();
+                resume(rv);
+            };
+
+            ex.post([h]() { h.resume(); });
+        });
 }
 
 #endif