@Test
    @DisplayName("reauthenticate performs call without exception")
    void reauthenticate_happy() throws CIFSException {
        session.reauthenticate();
        verify(session).reauthenticate();
    }

    // Error propagation: reauthenticate throws CIFSException
    @Test
    @DisplayName("reauthenticate throws CIFSException when underlying call fails")
    void reauthenticate_throws() throws CIFSException {

     * Sets a specific flag
     * @param flag the flag to set
     */
    public void setFlag(final int flag) {
        flags |= flag;
    }

    /**
     * Get the result of the DCERPC call.
     * @return result exception if the call failed, null otherwise
     */
    public DcerpcException getResult() {
        if (result != 0) {
            return new DcerpcException(result);
        }
        return null;
    }

		// of such a bucket. This is needed here as we identify such
		// buckets here while listing buckets. As part of regular
		// globalBucketMetadataSys.Init() call would get a valid
		// buckets only and not the quourum lost ones like this, so
		// explicit call
		for bktName, count := range bucketsMap {
			if count < quorum {
				// Queue a bucket heal task
				globalMRFState.addPartialOp(PartialOperation{

governed by a BSD-style
L3::: license that can be found in the LICENSE file.
L4:
L5:@echo off
L6:
L7:setlocal
L8:
L9:if not exist make.bat (
L10:    echo all.bat must be run from go\src
L11:    exit /b 1
L12:)
L13:
L14:call .\make.bat --no-banner || exit /b 1
L15:call .\run.bat --no-rebuild || exit /b 1
L16:..\bin\go tool dist banner
...

     * we must return it in the following next() call even if it was in the process of being removed
     * when hasNext() was called.
     */
    private @Nullable E nextItem;

    /**
     * Index of element returned by most recent call to next. Reset to -1 if this element is deleted
     * by a call to remove.
     */
    private int lastRet;

    Itr() {
      lastRet = -1;

///

## Other Asynchronous Function Calls { #other-asynchronous-function-calls }

As the testing function is now asynchronous, you can now also call (and `await`) other `async` functions apart from sending requests to your FastAPI application in your tests, exactly as you would call them anywhere else in your code.

/// tip

@NullUnmarked
public class ObjectsTest extends TestCase {

  @SuppressWarnings({
    "ObjectEqualsForPrimitives", // test of a trivial call
    "EqualsInteger", // test of a trivial call
    "EqualsLong", // b/273939864
    "EqualsDouble", // b/273939864
    "EqualsFloat", // b/273939864
    "YodaCondition", // test of reversed call
  })
  public void testEqual() throws Exception {
    assertTrue(Objects.equal(1, 1));

        } else {
            buf.append('"').append(StringEscapeUtils.escapeJson(value.toString())).append('"');
        }
        return buf;
    }

    /**
     * Get the write call for search log ndjson.
     * @return The write call.
     */
    public static Consumer<Writer> getSearchLogNdjsonWriteCall() {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();

    long toWaitMillis = 3500 - NANOSECONDS.toMillis(System.nanoTime() - thread.startTime);
    Thread.sleep(toWaitMillis);
    thread.setPriority(Thread.MAX_PRIORITY);
    Thread.class.getMethod("resume").invoke(thread);
    thread.join();
    // It's possible to race and suspend the thread just before the park call actually takes effect,

        params.put("test", "value");

        assertNull(queryRescorer.evaluate(params)); // First call - odd
        assertNotNull(queryRescorer.evaluate(params)); // Second call - even
        assertNull(queryRescorer.evaluate(params)); // Third call - odd
        assertNotNull(queryRescorer.evaluate(params)); // Fourth call - even
    }

    /**
     * Creates a mock RescorerBuilder for testing purposes.