new TreeSet<Object>((Comparator<Object>) NATURAL_ORDER), false);

  static <E> ImmutableSortedSet<E> emptySet(Comparator<? super E> comparator) {
    checkNotNull(comparator);
    if (NATURAL_ORDER.equals(comparator)) {
      return of();
    } else {
      return new RegularImmutableSortedSet<E>(new TreeSet<E>(comparator), false);
    }
  }

                  critical = false,
                  value =
                    (
                      "3025302306082b060105050730018617687474703a2f2f6f6373702e656" +
                        "e74727573742e6e6574"
                    ).decodeHex(),
                ),
                Extension(
                  id = crlDistributionPoints,
                  critical = false,
                  value =

    session = Session()
    try:
        yield session
    finally:
        session.open = False


def dep_session() -> Any:
    with acquire_session() as s:
        yield s


def broken_dep_session() -> Any:
    with acquire_session() as s:
        s.open = False
        yield s


SessionDep = Annotated[Session, Depends(dep_session)]

    }

    @Test
    public void test_loginFailure() {
        activityHelper.useEcsFormat = false;
        activityHelper.loginFailure(OptionalThing.empty());
        assertEquals("action:LOGIN_FAILURE", localLogMsg.get());
    }

    @Test
    public void test_logout() {
        activityHelper.useEcsFormat = false;
        activityHelper.logout(OptionalThing.empty());

        // Given
        when(mockDelegate.isUseSMB2OnlyNegotiation()).thenReturn(true);
        when(mockDelegate.isRequireSecureNegotiate()).thenReturn(false);
        when(mockDelegate.isSendNTLMTargetName()).thenReturn(true);
        when(mockDelegate.isPort139FailoverEnabled()).thenReturn(false);
        when(mockDelegate.isDfsStrictView()).thenReturn(true);

        // When

    "-PtestJavaVendor=$testJavaVendor",
    "-PautoDownloadAndroidStudio=true",
    "-PrunAndroidStudioInHeadlessMode=true",
    "-Dorg.gradle.java.installations.auto-download=false",
    "-Porg.gradle.java.installations.auto-download=false",
) + os.javaInstallationLocations(arch) +
    listOf(
        "-Porg.gradle.performance.branchName" to "%teamcity.build.branch%",

	// Output:
	// true
	// false
	// true
	// true
	// false
}

func ExampleContainsFunc() {
	f := func(r rune) bool {
		return r >= 'a' && r <= 'z'
	}
	fmt.Println(bytes.ContainsFunc([]byte("HELLO"), f))
	fmt.Println(bytes.ContainsFunc([]byte("World"), f))
	// Output:
	// false
	// true
}

func ExampleCount() {

   * be transmitted before the close message is sent but subsequent calls to [send] will return
   * false and their messages will not be enqueued.
   *
   * This returns true if a graceful shutdown was initiated by this call. It returns false if
   * a graceful shutdown was already underway or if the web socket is already closed or canceled.
   *
   * @param code Status code as defined by

     *
     * @return true if the crawler is running, false otherwise
     */
    public boolean isCrawlerRunning() {
        return crawlerRunning;
    }

    /**
     * Sets the crawler running status.
     *
     * @param crawlerRunning true to indicate the crawler is running, false otherwise
     */
    public void setCrawlerRunning(final boolean crawlerRunning) {

    assertTrue(service.shutDownCalled);
  }

  private class WaitOnRunService extends AbstractExecutionThreadService {
    private boolean startUpCalled = false;
    private boolean runCalled = false;
    private boolean shutDownCalled = false;
    private State expectedShutdownState = State.STOPPING;

    @Override
    protected void startUp() {
      assertFalse(startUpCalled);
      assertFalse(runCalled);