docs: private boolean isContinueWork() {
      long maxSpoutPending = TypeUtils.getLong(config.get(Config.TOPOLOGY_MAX_SPOUT_PENDING));
      return helper.getTopologyState().equals(TopologyAPI.TopologyState.RUNNING)
          &&
          ((!ackEnabled && collector.isOutQueuesAvailable())
              ||
              (ackEnabled
                  && collector.isOutQueuesAvailable()
                  && collector.numInFlight() < maxSpoutPending)
              ||
              (ackEnabled && !streamInQueue.isEmpty()));
    }