Examples use flat_buffer

fix #1488

CHANGELOG.md

@@ -2,6 +2,7 @@ Version 225:
 
 * Tidy up an unused function
 * Fix wsload jamfile
+* Examples use flat_buffer
 
 --------------------------------------------------------------------------------
 

example/websocket/client/async-ssl/websocket_client_async_ssl.cpp

@@ -47,7 +47,7 @@ class session : public std::enable_shared_from_this<session>
     tcp::resolver resolver_;
     websocket::stream<
         beast::ssl_stream<beast::tcp_stream>> ws_;
-    beast::multi_buffer buffer_;
+    beast::flat_buffer buffer_;
     std::string host_;
     std::string text_;
 

example/websocket/client/async/websocket_client_async.cpp

@@ -41,7 +41,7 @@ class session : public std::enable_shared_from_this<session>
 {
     tcp::resolver resolver_;
     websocket::stream<beast::tcp_stream> ws_;
-    beast::multi_buffer buffer_;
+    beast::flat_buffer buffer_;
     std::string host_;
     std::string text_;
 

example/websocket/client/coro-ssl/websocket_client_coro_ssl.cpp

@@ -108,7 +108,7 @@ do_session(
         return fail(ec, "write");
 
     // This buffer will hold the incoming message
-    beast::multi_buffer buffer;
+    beast::flat_buffer buffer;
 
     // Read a message into our buffer
     ws.async_read(buffer, yield[ec]);

example/websocket/client/coro/websocket_client_coro.cpp

@@ -93,7 +93,7 @@ do_session(
         return fail(ec, "write");
 
     // This buffer will hold the incoming message
-    beast::multi_buffer buffer;
+    beast::flat_buffer buffer;
 
     // Read a message into our buffer
     ws.async_read(buffer, yield[ec]);

example/websocket/client/sync-ssl/websocket_client_sync_ssl.cpp

@@ -89,7 +89,7 @@ int main(int argc, char** argv)
         ws.write(net::buffer(std::string(text)));
 
         // This buffer will hold the incoming message
-        beast::multi_buffer buffer;
+        beast::flat_buffer buffer;
 
         // Read a message into our buffer
         ws.read(buffer);

example/websocket/client/sync/websocket_client_sync.cpp

@@ -76,7 +76,7 @@ int main(int argc, char** argv)
         ws.write(net::buffer(std::string(text)));
 
         // This buffer will hold the incoming message
-        beast::multi_buffer buffer;
+        beast::flat_buffer buffer;
 
         // Read a message into our buffer
         ws.read(buffer);

example/websocket/server/async-ssl/websocket_server_async_ssl.cpp

@@ -50,7 +50,7 @@ class session : public std::enable_shared_from_this<session>
 {
     websocket::stream<
         beast::ssl_stream<beast::tcp_stream>> ws_;
-    beast::multi_buffer buffer_;
+    beast::flat_buffer buffer_;
 
 public:
     // Take ownership of the socket

example/websocket/server/async/websocket_server_async.cpp

@@ -44,7 +44,7 @@ fail(beast::error_code ec, char const* what)
 class session : public std::enable_shared_from_this<session>
 {
     websocket::stream<beast::tcp_stream> ws_;
-    beast::multi_buffer buffer_;
+    beast::flat_buffer buffer_;
 
 public:
     // Take ownership of the socket

example/websocket/server/coro-ssl/websocket_server_coro_ssl.cpp

@@ -88,7 +88,7 @@ do_session(
     for(;;)
     {
         // This buffer will hold the incoming message
-        beast::multi_buffer buffer;
+        beast::flat_buffer buffer;
 
         // Read a message
         ws.async_read(buffer, yield[ec]);

example/websocket/server/coro/websocket_server_coro.cpp

@@ -70,7 +70,7 @@ do_session(
     for(;;)
     {
         // This buffer will hold the incoming message
-        beast::multi_buffer buffer;
+        beast::flat_buffer buffer;
 
         // Read a message
         ws.async_read(buffer, yield[ec]);

example/websocket/server/fast/websocket_server_fast.cpp

@@ -99,7 +99,7 @@ do_sync_session(websocket::stream<beast::tcp_stream>& ws)
 
     for(;;)
     {
-        beast::multi_buffer buffer;
+        beast::flat_buffer buffer;
         
         ws.read(buffer, ec);
         if(ec == websocket::error::closed)
@@ -141,7 +141,7 @@ do_sync_listen(
 class async_session : public std::enable_shared_from_this<async_session>
 {
     websocket::stream<beast::tcp_stream> ws_;
-    beast::multi_buffer buffer_;
+    beast::flat_buffer buffer_;
 
 public:
     // Take ownership of the socket
@@ -355,7 +355,7 @@ do_coro_session(
 
     for(;;)
     {
-        beast::multi_buffer buffer;
+        beast::flat_buffer buffer;
 
         ws.async_read(buffer, yield[ec]);
         if(ec == websocket::error::closed)

example/websocket/server/stackless-ssl/websocket_server_stackless_ssl.cpp

@@ -52,7 +52,7 @@ class session
     , public std::enable_shared_from_this<session>
 {
     websocket::stream<beast::ssl_stream<beast::tcp_stream>> ws_;
-    beast::multi_buffer buffer_;
+    beast::flat_buffer buffer_;
 
 public:
     // Take ownership of the socket

example/websocket/server/stackless/websocket_server_stackless.cpp

@@ -47,7 +47,7 @@ class session
     , public std::enable_shared_from_this<session>
 {
     websocket::stream<beast::tcp_stream> ws_;
-    beast::multi_buffer buffer_;
+    beast::flat_buffer buffer_;
 
 public:
     // Take ownership of the socket

example/websocket/server/sync-ssl/websocket_server_sync_ssl.cpp

@@ -63,7 +63,7 @@ do_session(tcp::socket& socket, ssl::context& ctx)
         for(;;)
         {
             // This buffer will hold the incoming message
-            beast::multi_buffer buffer;
+            beast::flat_buffer buffer;
 
             // Read a message
             ws.read(buffer);

example/websocket/server/sync/websocket_server_sync.cpp

@@ -54,7 +54,7 @@ do_session(tcp::socket& socket)
         for(;;)
         {
             // This buffer will hold the incoming message
-            beast::multi_buffer buffer;
+            beast::flat_buffer buffer;
 
             // Read a message
             ws.read(buffer);

test/bench/wsload/wsload.cpp

@@ -115,7 +115,7 @@ class connection
     test_buffer const& tb_;
     net::strand<
         net::io_context::executor_type> strand_;
-    beast::multi_buffer buffer_;
+    beast::flat_buffer buffer_;
     std::mt19937_64 rng_;
     std::size_t count_ = 0;
     std::size_t bytes_ = 0;