if (host in insecureHosts) return listOf()
    try {
      val method =
        checkServerTrustedMethod
          ?: throw CertificateException("Failed to call checkServerTrusted")
      return method.invoke(delegate, chain, authType, host) as List<Certificate>
    } catch (e: InvocationTargetException) {
      throw e.targetException
    }
  }

  override fun getAcceptedIssuers(): Array<X509Certificate> = delegate.acceptedIssuers

            PluginContainer childContainer, PluginContainer parentContainer, boolean handleAsInheritance) {
        throw new UnsupportedOperationException();
    }

    public static List<Plugin> orderAfterMerge(
            List<Plugin> merged, List<Plugin> highPrioritySource, List<Plugin> lowPrioritySource) {
        throw new UnsupportedOperationException();
    }

  /** Cleans up anything created when creating the source or sink. */
  void tearDown() throws IOException;

  /** Factory for byte or char sources. */
  interface SourceFactory<S, T> extends SourceSinkFactory<S, T> {

    /** Creates a new source containing some or all of the given data. */
    S createSource(T data) throws IOException;
  }

  /** Factory for byte or char sinks. */

import java.sql.Timestamp;
import java.util.Date;

import org.junit.Test;

/**
 * @author higa
 *
 */
public class DateConverterTest {

    /**
     * @throws Exception
     */
    @Test
    public void testGetAsObjectAndGetAsString() throws Exception {
        final DateConverter converter = new DateConverter("yyyy/MM/dd");
        final Date result = (Date) converter.getAsObject("2008/01/16");

import static org.junit.Assert.assertThat;

import org.junit.Test;

/**
 * @author higa
 */
public class TimeConverterTest {

    /**
     * @throws Exception
     */
    @Test
    public void testGetAsObjectAndGetAsString() throws Exception {
        final TimeConverter converter = new TimeConverter("HH:mm:ss");
        final java.sql.Time result = (java.sql.Time) converter.getAsObject("12:34:56");

  public void testCatching() throws Exception {
    FluentFuture<?> f =
        FluentFuture.from(immediateFailedFuture(new CustomRuntimeException()))
            .catching(Throwable.class, Object::getClass, directExecutor());
    assertThat(f.get()).isEqualTo(CustomRuntimeException.class);
  }

  public void testCatchingAsync() throws Exception {
    FluentFuture<?> f =

    @Mock
    private CommonServerMessageBlock mockMessage;

    private ChannelLoadBalancer loadBalancer;
    private ChannelInfo channel1;
    private ChannelInfo channel2;

    @BeforeEach
    void setUp() throws UnknownHostException {
        loadBalancer = new ChannelLoadBalancer(mockChannelManager);

        InetAddress addr1 = InetAddress.getByName("192.168.1.100");
        InetAddress addr2 = InetAddress.getByName("192.168.1.101");

    Comparable<?> endpoint() {
      throw new IllegalStateException("range unbounded on this side");
    }

    @Override
    boolean isLessThan(Comparable<?> value) {
      return true;
    }

    @Override
    BoundType typeAsLowerBound() {
      throw new IllegalStateException();
    }

    @Override
    BoundType typeAsUpperBound() {

import org.junit.jupiter.api.Test;

public class RankFusionProcessorTest extends UnitFessTestCase {

    private static final String ID_FIELD = "_id";

    @Test
    public void test_default_1000docs_10size() throws Exception {
        String query = "*";
        int allRecordCount = 1000;
        int pageSize = 10;
        try (RankFusionProcessor rankFusionProcessor = new RankFusionProcessor()) {

   * {@link #addNode(Object) add} each missing endpoint to the graph.
   *
   * @return {@code true} if the graph was modified as a result of this call
   * @throws IllegalArgumentException if the introduction of the edge would violate {@link
   *     #allowsSelfLoops()}
   * @throws IllegalArgumentException if the endpoints are unordered and the graph is directed
   * @since 27.1
   */
  @CanIgnoreReturnValue