pub fn new(stream: T) -> Self {
        Self {
            stream,
            tx_waker: Arc::new(Default::default()),
            last_hb: None,
            __marker: PhantomData,
        }
    }
/// Add heartbeat response mechanism to the underlying bililive stream.
Add heartbeat response mechanism to the underlying bililive stream.
Add heartbeat response mechanism to the underlying bililive stream .
pub fn new(stream: T) -> Self {
        Self {
            stream,
            tx_waker: Arc::new(Default::default()),
            last_hb: None,
            __marker: PhantomData,
        }
    }
pub fn new ( stream : T ) -> Self { Self { stream , tx_waker : Arc :: new ( Default :: default ( ) ) , last_hb : None , __marker : PhantomData , } }
Add heartbeat response mechanism to the underlying bililive stream.
Add heartbeat response mechanism to the underlying bililive stream .
stream
T
stream
T