* stream may perform better.
   *
   * @see Stream#concat(Stream, Stream)
   */
  @SuppressWarnings("unchecked") // could probably be avoided with a forwarding Spliterator
  @SafeVarargs
  public static <T extends @Nullable Object> Stream<T> concat(Stream<? extends T>... streams) {
    // TODO(lowasser): consider an implementation that can support SUBSIZED

    public void setId_Equal(String id) {
        setId_Term(id, null);
    }

    public void setId_Equal(String id, ConditionOptionCall<TermQueryBuilder> opLambda) {
        setId_Term(id, opLambda);
    }

    public void setId_Term(String id) {
        setId_Term(id, null);
    }

    public void setId_Term(String id, ConditionOptionCall<TermQueryBuilder> opLambda) {

  }

  @GwtIncompatible
  public void testMin_noArgs() {
    assertThrows(IllegalArgumentException.class, () -> min());
  }

  public void testMin() {
    assertThat(min(LEAST)).isEqualTo(LEAST);
    assertThat(min(GREATEST)).isEqualTo(GREATEST);
    assertThat(min((int) 8, (int) 6, (int) 7, (int) 5, (int) 3, (int) 0, (int) 9))
        .isEqualTo((int) 0);
  }

  public void testConstrainToRange() {

@GwtCompatible
@NullUnmarked
public class VerifyTest extends TestCase {
  public void testVerify_simple_success() {
    verify(true);
  }

  public void testVerify_simple_failure() {
    assertThrows(VerifyException.class, () -> verify(false));
  }

  public void testVerify_simpleMessage_success() {
    verify(true, "message");
  }

  public void testVerify_simpleMessage_failure() {

    }

    @Override
    public void debug(Throwable error) {
        logger.debug("", error);
    }

    @Override
    public void info(CharSequence content) {
        logger.info(toString(content));
    }

    @Override
    public void info(CharSequence content, Throwable error) {
        logger.info(toString(content), error);
    }

    @Override
    public void info(Throwable error) {

            opLambda.callback(builder);
        }
    }

    public void setCreatedBy_Terms() {
        setCreatedBy_Terms(null);
    }

    public void setCreatedBy_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda) {
        setCreatedBy_Terms("createdBy", opLambda, null);
    }

            assertEquals("validate should return void", void.class, validateMethod.getReturnType());

        } catch (NoSuchMethodException e) {
            fail("All expected public methods should exist: " + e.getMessage());
        }
    }

    @Test
    public void test_constant_WEB_API_EXCEPTION() {
        // Test that the constant WEB_API_EXCEPTION is used correctly

            return executeType;
        }

        public void setExecuteType(String executeType) {
            this.executeType = executeType;
        }

        public void setExecuteResult(String executeResult) {
            this.executeResult = executeResult;
        }

        public void setThrowException(boolean throwException) {
            this.throwException = throwException;
        }

        public void columnId() {
            doColumn("_id");
        }

        public void columnBoost() {
            doColumn("boost");
        }

        public void columnCreatedBy() {
            doColumn("createdBy");
        }

        public void columnCreatedTime() {
            doColumn("createdTime");
        }

        public void columnPermissions() {
            doColumn("permissions");

    Callable<@Nullable Void> completeSuccessfullyRunnable =
        () -> {
          if (currentFuture.get().set("set")) {
            numSuccessfulSetCalls.incrementAndGet();
          }
          awaitUnchecked(barrier);
          return null;
        };
    Callable<@Nullable Void> completeExceptionallyRunnable =
        new Callable<@Nullable Void>() {