StreamChecker.java

package com.github.dakusui.pcond.core.fluent.builtins;

import com.github.dakusui.pcond.core.fluent.AbstractObjectChecker;

import com.github.dakusui.pcond.forms.Predicates;

import java.util.function.Function;

import java.util.function.Predicate;

import java.util.function.Supplier;

import java.util.stream.Stream;

import static com.github.dakusui.pcond.internals.InternalUtils.trivialIdentityFunction;

public interface StreamChecker<

    T,

    E> extends

    AbstractObjectChecker<

        StreamChecker<T, E>,

        T,

        Stream<E>> {

  default StreamChecker<T, E> noneMatch(Predicate<E> p) {

    return this.checkWithPredicate(Predicates.noneMatch(p));

  }

  default StreamChecker<T, E> anyMatch(Predicate<E> p) {

    return this.checkWithPredicate(Predicates.anyMatch(p));

  }

  default StreamChecker<T, E> allMatch(Predicate<E> p) {

    return this.checkWithPredicate(Predicates.allMatch(p));

  }

  class Impl<

      T,

      E> extends

      Base<

          StreamChecker<T, E>,

          T,

          Stream<E>

          >

      implements StreamChecker<T, E> {

    public Impl(Supplier<T> rootValue, Function<T, Stream<E>> root) {

      super(rootValue, root);

    }

    @Override

    protected StreamChecker<Stream<E>, E> rebase() {

      return new Impl<>(this::value, trivialIdentityFunction());

    }

  }

}

Active mutators

• CONDITIONALS_BOUNDARY
• EMPTY_RETURNS
• FALSE_RETURNS
• INCREMENTS
• INVERT_NEGS
• MATH
• NEGATE_CONDITIONALS
• NULL_RETURNS
• PRIMITIVE_RETURNS
• TRUE_RETURNS
• VOID_METHOD_CALLS

Tests examined

• com.github.dakusui.pcond.types.StreamTest.streamTestFailure(com.github.dakusui.pcond.types.StreamTest) (3 ms)
• com.github.dakusui.pcond.types.StreamTest.streamTest(com.github.dakusui.pcond.types.StreamTest) (5 ms)
• com.github.dakusui.ut.thincrest.ut.styles.MoreFluentStreamTest.test_allMatch(com.github.dakusui.ut.thincrest.ut.styles.MoreFluentStreamTest) (0 ms)
• com.github.dakusui.ut.thincrest.ut.styles.MoreFluentStreamTest.test_anyMatch(com.github.dakusui.ut.thincrest.ut.styles.MoreFluentStreamTest) (1 ms)
• com.github.dakusui.ut.thincrest.ut.styles.MoreFluentStreamTest.test_noneMatche(com.github.dakusui.ut.thincrest.ut.styles.MoreFluentStreamTest) (0 ms)
• com.github.dakusui.ut.thincrest.ut.styles.MoreFluentListTest.test_stream(com.github.dakusui.ut.thincrest.ut.styles.MoreFluentListTest) (2 ms)
• com.github.dakusui.pcond.types.StreamTest.streamTransformerTest(com.github.dakusui.pcond.types.StreamTest) (0 ms)
• com.github.dakusui.pcond.types.StreamTest.streamTransformerTestFailure(com.github.dakusui.pcond.types.StreamTest) (1 ms)