CurvePreferences: crypto.TLSCurveIDs(),
		TCPOptions:       globalTCPOptions,
		EnableHTTP2:      false,
	}

	if clientCert != "" && clientKey != "" {
		ctx, cancel := context.WithTimeout(context.Background(), time.Second)
		defer cancel()
		transport, err := s.NewHTTPTransportWithClientCerts(ctx, clientCert, clientKey)
		if err != nil {

			}
			if authZInit {
				setGlobalAuthZPlugin(polplugin.New(authZPluginCfg))
			}
		}

		if !openidInit || !ldapInit || !authNInit || !authZInit {
			retryInterval := time.Duration(r.Float64() * float64(3*time.Second))
			if !openidInit {
				logger.Info("Waiting for OpenID to be initialized.. (retrying in %s)", retryInterval)
			}
			if !ldapInit {

      T first = shuffledList.get(0);
      T second = shuffledList.get(1);
      T third = shuffledList.get(2);
      T[] rest = shuffledList.subList(3, shuffledList.size()).toArray(emptyArray);

      assertEquals(min, ordering.min(shuffledList));
      assertEquals(min, ordering.min(shuffledList.iterator()));
      assertEquals(min, ordering.min(first, second, third, rest));
      assertEquals(min, ordering.min(min, max));

      T first = shuffledList.get(0);
      T second = shuffledList.get(1);
      T third = shuffledList.get(2);
      T[] rest = shuffledList.subList(3, shuffledList.size()).toArray(emptyArray);

      assertEquals(min, ordering.min(shuffledList));
      assertEquals(min, ordering.min(shuffledList.iterator()));
      assertEquals(min, ordering.min(first, second, third, rest));
      assertEquals(min, ordering.min(min, max));

        assertEquals(0, session.getMessageCount());

        session.addUserMessage("First");
        assertEquals(1, session.getMessageCount());

        session.addAssistantMessage("Second");
        assertEquals(2, session.getMessageCount());
    }

    @Test
    public void test_getMessageCountWithNullMessages() {
        final ChatSession session = new ChatSession();

        RankFusionProcessor processor = new RankFusionProcessor();
        processor.setSearcher(new TestSearcher(100));
        processor.init();

        // First close
        processor.close();
        // Second close - should not throw exception
        processor.close();
    }

    /**
     * Test searcher that returns configurable number of documents.
     */

                    } finally {
                        latch.countDown();
                    }
                }).start();
            }

            latch.await(5, java.util.concurrent.TimeUnit.SECONDS);
            assertEquals(5, successCount.get(), "All concurrent calls should succeed");
        }
    }

    The HTTP authorization credentials in the result of using `HTTPBearer` or
    `HTTPDigest` in a dependency.

    The HTTP authorization header value is split by the first space.

    The first part is the `scheme`, the second part is the `credentials`.

    For example, in an HTTP Bearer token scheme, the client will send a header
    like:

    ```
    Authorization: Bearer deadbeef12346
    ```

    In this case:

        assertNotNull(polled);
        assertEquals("http://www.example.com/page1", polled.getUrl());
        assertEquals(sessionId, polled.getSessionId());

        // Second poll should return null (queue is empty)
        final OpenSearchUrlQueue polled2 = urlQueueService.poll(sessionId);
        assertNull(polled2);

        urlQueueService.delete(sessionId);
    }

    @Test

        boolean firstCreate = suggester.createIndexIfNothing();
        assertTrue("First call should create index", firstCreate);

        boolean secondCreate = suggester.createIndexIfNothing();
        assertFalse("Second call should return false (already exists)", secondCreate);
    }

    @Test
    public void test_createIndexIfNothing_multipleCallsAreSafe() throws Exception {
        Suggester suggester = createSuggester();