code: public void cleanup ()
      {
          // tell any pending object subscribers that they're not getting their bits
          for (PendingRequest<?> req : _penders.values()) {
              for (Subscriber<?> sub : req.targets) {
                  sub.requestFailed(req.oid, new ObjectAccessException("Client connection closed"));
              }
          }
          _penders.clear();
          _flusher.cancel();
          _flushes.clear();
          _dead.clear();
          _client.getRunQueue().postRunnable(new Runnable() {
              public void run () {
                  _ocache.clear();
              }
          });
      }
docs: Called when the client is cleaned up due to having disconnected from the server.