code: protected T newSession(IoSessionInitializer<? extends IoFuture> initializer, IoFuture future, Callable<T> sessionCreator) throws Exception {
          T session;
  
          IoProcessorEx<T> processor = getProcessor();
          synchronized (processor) {
              session = sessionCreator.call();
              processor.add(session);
          }
  
          initSession(session, future, initializer);
          IoFilterChain filterChain = session.getFilterChain();
  
          try {
              this.getFilterChainBuilder().buildFilterChain(filterChain);
          } catch (Throwable t) {
              ExceptionMonitor.getInstance().exceptionCaught(t, session);
          }
  
          addLoggerFilter(session, getLogger());
  
          getListeners().fireSessionCreated(session);
          return session;
      }
docs: wtb closures