code: @Override
      public void sessionClosed(IoSession session) throws Exception {
          final InputStream in = (InputStream) session.getAttribute(KEY_IN);
          final OutputStream out = (OutputStream) session.getAttribute(KEY_OUT);
          try {
              in.close();
          } finally {
              out.close();
          }
      }
docs: Closes streams