bililive 0.1.2

A simple stream-based bilibili live client library.
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
55
56
57
58
59

//! Connection related functions and types.
macro_rules! impl_connect_mod {
    ($adapter:ident) => {
        use async_tungstenite::tungstenite::{error::Error as WsError, Message};
        use async_tungstenite::$adapter::ConnectStream;
        use async_tungstenite::WebSocketStream;
        use stream_reconnect::{ReconnectStream, UnderlyingStream};

        use crate::config::{RetryConfig, StreamConfig};
        use crate::errors::Result;
        use crate::stream::retry::RetryContext;
        use crate::stream::BililiveStream;

        pub type InnerStream = WebSocketStream<ConnectStream>;
        pub type InnerRetryStream = ReconnectStream<
            WebSocketStream<ConnectStream>,
            RetryContext,
            std::result::Result<Message, WsError>,
            WsError,
        >;
        pub type DefaultStream = BililiveStream<InnerStream>;
        pub type RetryStream = BililiveStream<InnerRetryStream>;

        /// Connect to bilibili live room.
        ///
        /// # Errors
        /// Returns an error when websocket connection fails.
        pub async fn connect(config: StreamConfig) -> Result<DefaultStream> {
            let inner = InnerStream::establish(config.into()).await?;
            Ok(BililiveStream::from_raw_stream(inner))
        }

        /// Connect to bilibili live room with auto retry.
        ///
        /// # Errors
        /// Returns an error when websocket connection fails.
        pub async fn connect_with_retry(
            stream_config: StreamConfig,
            retry_config: RetryConfig,
        ) -> Result<RetryStream> {
            let inner: InnerRetryStream =
                ReconnectStream::connect_with_options(stream_config.into(), retry_config.into())
                    .await?;
            Ok(BililiveStream::from_raw_stream(inner))
        }
    };
}

#[cfg(feature = "tokio")]
pub mod tokio {
    //! `tokio` integration.
    impl_connect_mod!(tokio);
}

#[cfg(feature = "async-std")]
pub mod async_std {
    //! `async_std` integration.
    impl_connect_mod!(async_std);
}