docs: @Override
    public void onSessionStarted(Session session) {
      session.setUseBlockingRead(true);
      session.setAttribute(HEART_BEAT_FAIL_COUNT_ATTR, new AtomicInteger(0));
      for (MemcachedClientStateListener listener : this.client.getStateListeners()) {
        listener.onConnected(this.client, session.getRemoteSocketAddress());
      }
      this.listener.onConnect((MemcachedTCPSession) session, this.client);
    }