Disable backpressure

src/net/tcp.rs

@@ -56,6 +56,7 @@ pub async fn establish_tcp_connection_with_opts(endpoint: &Address, tcp_opts: &T
     Ok(tcp_stream)
 }
 
+#[allow(unused_imports, unused_variables)]
 pub mod listener {
 
     use super::connection::{LurkTcpConnection, LurkTcpConnectionFactory, LurkTcpConnectionLabel};
@@ -68,7 +69,7 @@ pub mod listener {
     /// Custom implementation of TCP listener.
     #[allow(dead_code)]
     pub struct LurkTcpListener {
-        incoming: Backpressure<TcpListenerStream>,
+        incoming: TcpListenerStream,
         factory: LurkTcpConnectionFactory,
         local_addr: SocketAddr,
     }
@@ -86,7 +87,7 @@ pub mod listener {
 
             // Create backpressure limit and supply the receiver to the created stream.
             let (bp_tx, bp_rx) = backpressure::new(conn_limit);
-            let incoming = TcpListenerStream::new(listener).apply_backpressure(bp_rx);
+            let incoming = TcpListenerStream::new(listener);
 
             Ok(LurkTcpListener {
                 incoming,
@@ -131,6 +132,7 @@ pub mod listener {
         /// should put on hold some of them and handle only allowed number of
         /// them in parallel.
         #[tokio::test]
+        #[ignore]
 
         async fn limit_tcp_connections() {
             let conn_limit = 5;