Implement idleTimeout

Author: arturobernalg

httpcore5-h2/src/main/java/org/apache/hc/core5/http2/impl/nio/AbstractH2StreamMultiplexer.java

@@ -1376,7 +1376,7 @@ private void initializeStreamTimeouts(final H2Stream stream) {
         if (streamIdleTimeout == null || !streamIdleTimeout.isEnabled()) {
             final Timeout socketTimeout = ioSession.getSocketTimeout();
             if (socketTimeout != null && socketTimeout.isEnabled()) {
-                stream.setIdleTimeout(socketTimeout);
+                stream.setTimeout(socketTimeout);
             }
         }
     }

httpcore5-h2/src/main/java/org/apache/hc/core5/http2/impl/nio/H2Stream.java

@@ -91,7 +91,7 @@ public State getState() {
 
     @Override
     public void setTimeout(final Timeout timeout) {
-        // not supported
+        this.idleTimeout = timeout;
     }
 
     boolean isReserved() {
@@ -362,10 +362,6 @@ Timeout getIdleTimeout() {
         return idleTimeout;
     }
 
-    void setIdleTimeout(final Timeout idleTimeout) {
-        this.idleTimeout = idleTimeout;
-    }
-
     Timeout getLifetimeTimeout() {
         return lifetimeTimeout;
     }

httpcore5/src/main/java/org/apache/hc/core5/reactor/IOSessionImpl.java

@@ -32,7 +32,6 @@
 import java.net.StandardSocketOptions;
 import java.nio.ByteBuffer;
 import java.nio.channels.ByteChannel;
-import java.nio.channels.CancelledKeyException;
 import java.nio.channels.SelectionKey;
 import java.nio.channels.SocketChannel;
 import java.util.Deque;
@@ -159,11 +158,7 @@ public SocketAddress getRemoteAddress() {
 
     @Override
     public int getEventMask() {
-        try {
-            return this.key.interestOps();
-        } catch (final CancelledKeyException ignore) {
-            return 0;
-        }
+        return this.key.interestOps();
     }
 
     @Override