add active stream prototype

src/client.rs

@@ -582,7 +582,6 @@ where
     }
 }
 
-#[cfg(feature = "unstable")]
 impl<B> SendRequest<B>
 where
     B: Buf,

src/proto/connection.rs

@@ -181,6 +181,10 @@ where
     pub(crate) fn max_recv_streams(&self) -> usize {
         self.inner.streams.max_recv_streams()
     }
+    /// Returns the number of active stream
+    pub(crate) fn active_streams(&self) -> usize {
+        self.inner.streams.num_active_streams()
+    }
 
     #[cfg(feature = "unstable")]
     pub fn num_wired_streams(&self) -> usize {
@@ -303,7 +307,9 @@ where
                                     ) {
                                         (Some(sleep), _) => {
                                             ready!(sleep.as_mut().poll(cx));
-                                            self.inner.as_dyn().go_away_now(Reason::KEEPALIVE_TIMEOUT);
+                                            self.inner
+                                                .as_dyn()
+                                                .go_away_now(Reason::KEEPALIVE_TIMEOUT);
                                             continue 'outer;
                                         }
                                         (None, Some(timeout)) => {

src/proto/streams/streams.rs

@@ -1008,7 +1008,6 @@ where
         self.inner.lock().unwrap().counts.max_recv_streams()
     }
 
-    #[cfg(feature = "unstable")]
     pub fn num_active_streams(&self) -> usize {
         let me = self.inner.lock().unwrap();
         me.store.num_active_streams()

src/server.rs

@@ -584,6 +584,15 @@ where
         self.connection.max_recv_streams()
     }
 
+    /// Returns whether has stream alive
+    pub fn has_streams_or_other_references(&self) -> bool {
+        self.connection.has_streams_or_other_references()
+    }
+    /// Returns the number of current active stream.
+    pub fn active_stream(&self) -> usize {
+        self.connection.active_streams()
+    }
+
     // Could disappear at anytime.
     #[doc(hidden)]
     #[cfg(feature = "unstable")]