Revert "Disable backpressure"

This reverts commit dadd0f5.

src/net/tcp.rs

@@ -56,7 +56,6 @@ 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};
@@ -69,7 +68,7 @@ pub mod listener {
     /// Custom implementation of TCP listener.
     #[allow(dead_code)]
     pub struct LurkTcpListener {
-        incoming: TcpListenerStream,
+        incoming: Backpressure<TcpListenerStream>,
         factory: LurkTcpConnectionFactory,
         local_addr: SocketAddr,
     }
@@ -87,7 +86,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);
+            let incoming = TcpListenerStream::new(listener).apply_backpressure(bp_rx);
 
             Ok(LurkTcpListener {
                 incoming,
@@ -132,7 +131,6 @@ 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;