protected Future evaluate()

in src/main/java/com/twitter/nodes/PredicateNode.java [55:65]

• 10 lines of code
• 2 McCabe index (conditional complexity)

  protected Future<Boolean> evaluate() throws Exception {
    SourceType sourceValue = sourceNode.emit();

    try {
      return Future.value(predicate.test(sourceValue));
    } catch (Exception e) {
      String msg = String.format("%s threw: sourceNode.emit() => %s", getName(), sourceValue);
      LOG.error(e, msg);
      return Future.exception(new RuntimeException(msg, e));
    }
  }