public static Enumerable where()

in src/main/java/net/hydromatic/linq4j/EnumerableDefaults.java [2021:2051]

• 28 lines of code
• 3 McCabe index (conditional complexity)

  public static <TSource> Enumerable<TSource> where(
      final Enumerable<TSource> source, final Predicate1<TSource> predicate) {
    assert predicate != null;
    return new AbstractEnumerable<TSource>() {
      public Enumerator<TSource> enumerator() {
        final Enumerator<TSource> enumerator = source.enumerator();
        return new Enumerator<TSource>() {
          public TSource current() {
            return enumerator.current();
          }

          public boolean moveNext() {
            while (enumerator.moveNext()) {
              if (predicate.apply(enumerator.current())) {
                return true;
              }
            }
            return false;
          }

          public void reset() {
            enumerator.reset();
          }

          public void close() {
            enumerator.close();
          }
        };
      }
    };
  }