/// Helper function to send error messages.
Helper function to send error messages.
Helper function to send error messages .
fn send_error_string(
    sink: &mpsc::UnboundedSender<WsMessage>,
    operation_id: String,
    error: String,
) -> Result<(), WsError> {
    sink.unbounded_send(OutgoingMessage::from_error_string(operation_id, error).into())
        .map_err(|_| WsError::Http(500))
}
fn send_error_string ( sink : & mpsc :: UnboundedSender < WsMessage > , operation_id : String , error : String , ) -> Result < ( ) , WsError > { sink . unbounded_send ( OutgoingMessage :: from_error_string ( operation_id , error ) . into ( ) ) . map_err ( | _ | WsError :: Http ( 500 ) ) }
Helper function to send error messages.
Helper function to send error messages .
sink
&mpsc::UnboundedSender<WsMessage>
operation_id
String
error
String