http server and route handlers use capy stream abstractions

Author: vinniefalco

example/server/main.cpp

@@ -65,20 +65,30 @@ int server_main( int argc, char* argv[] )
 
     corosio_router rr;
     rr.use( http::cors() );
+    rr.use(
+        [&]( auto& rp ) -> http::route_task
+        {
+            //co_return co_await rp.send("Hello, World!");
+            auto [ec] = co_await rp.send("Hello, World!");
+            co_return ec;
+        });
+#if 1
     rr.use(
         [&]( auto& rp ) -> http::route_task
         {
             if(rp.req.method() != http::method::post)
                 co_return http::route::next;
             http::json_sink js;
-            auto [ec, n] = co_await capy::push_to(rp.req_bufs, js);
+            auto [ec, n] = co_await capy::push_to(rp.req_body, js);
             if(ec.failed())
                 co_return ec;
-            (void)n;
+            //(void)n;
             json::value jv = js.release();
             co_return {};
+
         });
-   rr.use( "/", http::serve_static( argv[3] ) );
+    rr.use( "/", http::serve_static( argv[3] ) );
+#endif
 
     http_server hsrv(
         ioc,

src/http_server.cpp

@@ -13,7 +13,8 @@
 #include <boost/capy/cond.hpp>
 #include <boost/capy/ex/strand.hpp>
 #include <boost/capy/io/any_read_source.hpp>
-#include <boost/capy/io/any_write_sink.hpp>
+#include <boost/capy/io/any_buffer_sink.hpp>
+#include <boost/capy/io/owning.hpp>
 #include <boost/beast2/corosio_router.hpp>
 #include <boost/http/request_parser.hpp>
 #include <boost/http/response.hpp>
@@ -49,9 +50,8 @@ struct http_server::
     capy::strand<corosio::io_context::executor_type> strand;
     corosio::socket sock;
     corosio_route_params rp;
-    http::serializer::sink<corosio::socket> ss;
     http::parser::source<corosio::socket> ps;
-    http::parser::buffer_source_adapter<corosio::socket> bs;
+    http::serializer::sink<corosio::socket> ss;
 
     worker(
         corosio::io_context& ctx_,
@@ -61,18 +61,17 @@ struct http_server::
         , strand(ctx_.get_executor())
         , sock(ctx_)
         , rp(sock)
+        , ps(rp.parser.source_for(sock))
+        , ss(rp.serializer.sink_for(sock))
     {
         sock.open();
 
         rp.parser = http::request_parser(srv->impl_->parser_cfg);
-        ps = rp.parser.source_for(sock);
-        bs = rp.parser.buffer_source_for(sock);
-        rp.req_body = capy::any_read_source(ps);
-        rp.req_bufs = capy::any_buffer_source(bs);
         rp.serializer = http::serializer(srv->impl_->serializer_cfg);
         rp.serializer.set_message(rp.res);
-        ss = rp.serializer.sink_for( sock );
-        rp.res_body = capy::any_write_sink(ss);
+
+        rp.req_body = capy::any_buffer_source(ps);
+        rp.res_body = capy::any_buffer_sink(ss);
     }
 
     corosio::socket& socket() override