Function subscribe

pub(crate) async fn subscribe(
    ws: &mut WebSocketStream<MaybeTlsStream<TcpStream>>,
    sid: &str,
    message_name: &str,
    topic: &str,
    verbose: bool,
) -> Result<(), String>

SUB and, when the server is verbose, the following +OK.