Add mux_shm_name parameter to WebSocketClient constructor

Author: kzhdev

include/coinbase/websocket.hpp

@@ -162,6 +162,7 @@ class WebSocketClient {
         WebsocketCallbacks *callbacks,
         std::string_view market_data_url = "wss://advanced-trade-ws.coinbase.com",
         std::string_view user_data_url = "wss://advanced-trade-ws-user.coinbase.com",
+        const char* mux_shm_name = nullptr,
         uint32_t md_read_buffer_size = 1u << 26,            // 64 MB reading buffer
         uint32_t md_record_size = 1u << 16,                 // 64K message records
         const char* md_read_buffer_shm_name = nullptr,      // default not using shared memory

src/websocket.cpp

@@ -181,6 +181,7 @@ WebSocketClient::WebSocketClient(
     WebsocketCallbacks *callbacks,
     std::string_view market_data_url,
     std::string_view user_data_url,
+    const char* mux_shm_name,
     uint32_t md_read_buffer_size,
     uint32_t md_record_size,
     const char* md_read_buffer_shm_name,
@@ -191,7 +192,7 @@ WebSocketClient::WebSocketClient(
 )
     : market_data_url_(market_data_url)
     , user_data_url_(user_data_url)
-    , owning_mux_(new slick::stream_buffer_multiplexer(std::max(md_record_size, user_record_size) * 2))
+    , owning_mux_(new slick::stream_buffer_multiplexer(std::max(md_record_size, user_record_size) * 2, mux_shm_name))
     , mux_(*owning_mux_.get())
     , producer_offset_(0)
     , user_thread_callbacks_(dynamic_cast<UserThreadWebsocketCallbacks*>(callbacks))