actix/actix-extras
1
0
Fork 0
mirror of https://github.com/actix/actix-extras.git synced 2024-11-23 23:51:06 +01:00
Code Issues Releases Wiki Activity

Fix doctests

Browse Source
This commit is contained in:
asonix 2024-11-04 18:17:20 -06:00
parent a66f20a106
commit bcc033d95c
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
actix-ws/src/lib.rs
View File

@ -40,7 +40,7 @@ pub use self::{
/// while let Some(Ok(msg)) = msg_stream.next().await { /// while let Some(Ok(msg)) = msg_stream.next().await {
/// match msg { /// match msg {
/// Message::Ping(bytes) => { /// Message::Ping(bytes) => {
/// if session.pong(&bytes).await.is_err() { /// if session.pong(bytes).await.is_err() {
/// return; /// return;
/// } /// }
/// } /// }

4
actix-ws/src/session.rs
View File

@ -98,7 +98,7 @@ impl Session {
/// ```no_run /// ```no_run
/// # use actix_ws::Session; /// # use actix_ws::Session;
/// # async fn test(mut session: Session) { /// # async fn test(mut session: Session) {
/// if session.ping(b"").await.is_err() { /// if session.ping(&b""[..]).await.is_err() {
/// // session is closed /// // session is closed
/// } /// }
/// # } /// # }
@ -122,7 +122,7 @@ impl Session {
/// # async fn test(mut session: Session, msg: Message) { /// # async fn test(mut session: Session, msg: Message) {
/// match msg { /// match msg {
/// Message::Ping(bytes) => { /// Message::Ping(bytes) => {
/// let _ = session.pong(&bytes).await; /// let _ = session.pong(bytes).await;
/// } /// }
/// _ => (), /// _ => (),
/// } /// }