Expose max locally-initiated concurrent_streams

quinn-proto/src/connection/mod.rs

@@ -1419,6 +1419,11 @@ impl Connection {
         self.streams.max_concurrent(dir)
     }
 
+    /// Current number of locally initiated streams that may be concurrently open
+    pub fn max_locally_initiated_concurrent_streams(&self, dir: Dir) -> u64 {
+        self.streams.max_locally_initiated_concurrent(dir)
+    }
+
     /// See [`TransportConfig::send_window()`]
     pub fn set_send_window(&mut self, send_window: u64) {
         self.streams.set_send_window(send_window);

quinn-proto/src/connection/streams/state.rs

@@ -870,6 +870,10 @@ impl StreamsState {
         self.allocated_remote_count[dir as usize]
     }
 
+    pub(crate) fn max_locally_initiated_concurrent(&self, dir: Dir) -> u64 {
+        self.max[dir as usize]
+    }
+
     pub(crate) fn set_send_window(&mut self, send_window: u64) {
         self.send_window = send_window;
     }

quinn/src/connection.rs

@@ -607,6 +607,25 @@ impl Connection {
             .clone_box()
     }
 
+    /// Current number of locally initiated unidirectional streams that may be concurrently open
+    pub fn max_locally_initiated_concurrent_uni_streams(&self) -> u64 {
+        let conn = self
+            .0
+            .state
+            .lock("max_locally_initiated_concurrent_streams");
+        conn.inner
+            .max_locally_initiated_concurrent_streams(Dir::Uni)
+    }
+
+    /// Current number of locally initiated bidirectional streams that may be concurrently open
+    pub fn max_locally_initiated_concurrent_bi_streams(&self) -> u64 {
+        let conn = self
+            .0
+            .state
+            .lock("max_locally_initiated_concurrent_streams");
+        conn.inner.max_locally_initiated_concurrent_streams(Dir::Bi)
+    }
+
     /// Succeeds when an incoming connection is proven not to be a replay attack.
     ///
     /// Only interesting for `Connection`s obtained from [`Connecting::into_0rtt`]. On 1-RTT