mirror of
https://github.com/fafhrd91/actix-web
synced 2024-11-24 00:21:08 +01:00
Improve awc websocket docs (#1654)
Co-authored-by: Rob Ede <robjtede@icloud.com>
This commit is contained in:
parent
9a9d4b182e
commit
c54d73e0bb
@ -193,7 +193,8 @@ impl Client {
|
|||||||
self.request(Method::OPTIONS, url)
|
self.request(Method::OPTIONS, url)
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Construct WebSockets request.
|
/// Initialize a WebSocket connection.
|
||||||
|
/// Returns a WebSocket connection builder.
|
||||||
pub fn ws<U>(&self, url: U) -> ws::WebsocketsRequest
|
pub fn ws<U>(&self, url: U) -> ws::WebsocketsRequest
|
||||||
where
|
where
|
||||||
Uri: TryFrom<U>,
|
Uri: TryFrom<U>,
|
||||||
|
@ -1,4 +1,31 @@
|
|||||||
//! Websockets client
|
//! Websockets client
|
||||||
|
//!
|
||||||
|
//! Type definitions required to use [`awc::Client`](../struct.Client.html) as a WebSocket client.
|
||||||
|
//!
|
||||||
|
//! # Example
|
||||||
|
//!
|
||||||
|
//! ```
|
||||||
|
//! use awc::{Client, ws};
|
||||||
|
//! use futures_util::{sink::SinkExt, stream::StreamExt};
|
||||||
|
//!
|
||||||
|
//! #[actix_rt::main]
|
||||||
|
//! async fn main() {
|
||||||
|
//! let (_resp, mut connection) = Client::new()
|
||||||
|
//! .ws("ws://echo.websocket.org")
|
||||||
|
//! .connect()
|
||||||
|
//! .await
|
||||||
|
//! .unwrap();
|
||||||
|
//!
|
||||||
|
//! connection
|
||||||
|
//! .send(ws::Message::Text("Echo".to_string()))
|
||||||
|
//! .await
|
||||||
|
//! .unwrap();
|
||||||
|
//! let response = connection.next().await.unwrap().unwrap();
|
||||||
|
//!
|
||||||
|
//! assert_eq!(response, ws::Frame::Text("Echo".as_bytes().into()));
|
||||||
|
//! }
|
||||||
|
//! ```
|
||||||
|
|
||||||
use std::convert::TryFrom;
|
use std::convert::TryFrom;
|
||||||
use std::net::SocketAddr;
|
use std::net::SocketAddr;
|
||||||
use std::rc::Rc;
|
use std::rc::Rc;
|
||||||
|
Loading…
Reference in New Issue
Block a user