fn spawn_ws_handler(
  sub_id: String,
  sub_tx_clone: Sender<SubscriptionRequest>,
  sreq_tx_clone: Sender<(String, SerialRequest)>,
  connection: WsUpgrade<TcpStream>,
) {
  thread::spawn(move || ws_handler(sub_id, &sub_tx_clone, &sreq_tx_clone, connection));
}
/// Spawn a websocket handler into its own thread
Spawn a websocket handler into its own thread
Spawn a websocket handler into its own thread
fn spawn_ws_handler(
  sub_id: String,
  sub_tx_clone: Sender<SubscriptionRequest>,
  sreq_tx_clone: Sender<(String, SerialRequest)>,
  connection: WsUpgrade<TcpStream>,
) {
  thread::spawn(move || ws_handler(sub_id, &sub_tx_clone, &sreq_tx_clone, connection));
}
fn spawn_ws_handler ( sub_id : String , sub_tx_clone : Sender < SubscriptionRequest > , sreq_tx_clone : Sender < ( String , SerialRequest ) > , connection : WsUpgrade < TcpStream > , ) { thread :: spawn ( move | | ws_handler ( sub_id , & sub_tx_clone , & sreq_tx_clone , connection ) ) ; }
Spawn a websocket handler into its own thread
Spawn a websocket handler into its own thread
sub_id
String
sub_tx_clone
Sender<SubscriptionRequest>
sreq_tx_clone
Sender<(String, SerialRequest)>
connection
WsUpgrade<TcpStream>
sub_id
String
sub_tx_clone
Sender<SubscriptionRequest>
sreq_tx_clone
Sender<(String, SerialRequest)>
connection
WsUpgrade<TcpStream>