pub(crate) async fn reconnector(
rx: Receiver<()>,
server: String,
client_ident: String,
sock_rd: Arc<RwLock<Option<SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>>>>,
sock_wr: Arc<RwLock<Option<SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>>>>,
) -> Result<()>