panda 0.5.3

An async Rust library for Discord
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

use crate::error::Result;
use async_tungstenite::{stream::Stream, WebSocketStream, tungstenite::Message};
use isahc::http;
use url::Url;

// ******************************
// TOKIO
// ******************************
#[cfg(feature = "tokio-runtime")]
use async_tungstenite::tokio::TokioAdapter;

#[cfg(feature = "tokio-runtime")]
pub(crate) type WebSocket = WebSocketStream<
    Stream<
        TokioAdapter<tokio::net::TcpStream>,
        TokioAdapter<tokio_tls::TlsStream<TokioAdapter<TokioAdapter<tokio::net::TcpStream>>>>,
    >,
>;
#[cfg(feature="tokio-runtime")]
pub(crate) type WebSocketSender = futures::stream::SplitSink<WebSocketStream<Stream<TokioAdapter<tokio::net::TcpStream>, TokioAdapter<tokio_tls::TlsStream<TokioAdapter<TokioAdapter<tokio::net::TcpStream>>>>>>, Message>;

#[cfg(feature = "tokio-runtime")]
pub(crate) async fn connect_async(url: Url) -> Result<(WebSocket, http::Response<()>)> {
    async_tungstenite::tokio::connect_async(url).await.map_err(|e| e.into())
}

// ******************************
// ASYNC-STD
// *****************************
#[cfg(feature = "async-std-runtime")]
pub(crate) type WebSocket = WebSocketStream<Stream<async_std::net::TcpStream, async_tls::client::TlsStream<async_std::net::TcpStream>>>;

#[cfg(feature = "async-std-runtime")]
pub(crate) type WebSocketSender = futures::stream::SplitSink<WebSocketStream<Stream<async_std::net::TcpStream, async_tls::client::TlsStream<async_std::net::TcpStream>>>, Message>;

#[cfg(feature = "async-std-runtime")]
pub(crate) async fn connect_async(url: Url) -> Result<(WebSocket, http::Response<()>)> {
    async_tungstenite::async_std::connect_async(url).await.map_err(|e| e.into())
}


// ******************************
// ASYNC-STD(NATIVE TLS)
// *****************************
// #[cfg(feature = "async-std-native-tls")]
// pub(crate) type WebSocket = WebSocketStream<Stream<async_std::net::TcpStream, async_native_tls::TlsStream<async_std::net::TcpStream>>>;

// #[cfg(feature = "async-std-native-tls")]
// pub(crate) type WebSocketSender = futures::stream::SplitSink<WebSocketStream<Stream<async_std::net::TcpStream, async_native_tls::TlsStream<async_std::net::TcpStream>>>, Message>;

// #[cfg(feature = "async-std-native-tls")]
// pub(crate) async fn connect_async(url: Url) -> Result<(WebSocket, http::Response<()>)> {
//     async_tungstenite::async_std::connect_async(url).await.map_err(|e| e.into())
// }