.collect(Collectors.toMap(Pair::getFirst, Pair::getSecond)));
            return result;
        } catch (InstantiationException | IllegalAccessException e) {
            final String msg = "Cannot create a new instance: " + entityType.getName();
            throw new IllegalBehaviorStateException(msg, e);
        }
    }

  @CollectionSize.Require(absent = {ZERO, ONE})
  public void testCreateWithDuplicates() {
    E[] array = createSamplesArray();
    array[1] = e0();
    collection = getSubjectGenerator().create(array);

    expectContents(array);
  }

    assertThrows(CancellationException.class, () -> getDone(immediateCancelledFuture()));
  }

  public void testPending() throws ExecutionException {
    assertThrows(IllegalStateException.class, () -> getDone(SettableFuture.create()));
  }

            } else {
                logger.debug("No synonym data.");
            }
        }
    }

    @Override
    public Tokenizer create() {
        return new NGramSynonymTokenizer(n, delimiters, expand, ignoreCase, synonymLoader);
    }

    suite.addTestSuite(SetsTest.class);

    suite.addTest(
        SetTestSuiteBuilder.using(
                new TestStringSetGenerator() {
                  @Override
                  protected Set<String> create(String[] elements) {
                    return Sets.newConcurrentHashSet(asList(elements));
                  }
                })
            .named("Sets.newConcurrentHashSet")

        @Test
        @DisplayName("Should create request with configuration only")
        void testConstructorWithConfig() {
            TestServerMessageBlock2Request request = new TestServerMessageBlock2Request(mockConfig);
            assertNotNull(request);
            assertEquals(mockConfig, request.getConfig());
        }

        @Test
        @DisplayName("Should create request with configuration and command")

```xml
<dependency>
    <groupId>org.codelibs.fess</groupId>
    <artifactId>fess-suggest</artifactId>
    <version>15.2.0-SNAPSHOT</version>
</dependency>
```

### Basic Usage

#### 1. Create Suggester Instance

```java
import org.codelibs.fess.suggest.Suggester;
import org.opensearch.client.Client;

// Initialize with your OpenSearch client
String suggestId = "my-suggest-index";

errors.invalid_query_cannot_process=Could not process the specified query.
errors.crud_invalid_mode = The mode is incorrect. (not {0}, but {1})
errors.crud_failed_to_create_instance = Failed to create a new data.
errors.crud_failed_to_create_crud_table = Failed to create a new data. ({0})
errors.crud_failed_to_update_crud_table=Failed to update the data. ({0})
errors.crud_failed_to_delete_crud_table=Failed to delete the data. ({0})

errors.invalid_query_cannot_process=Could not process the specified query.
errors.crud_invalid_mode = The mode is incorrect. (not {0}, but {1})
errors.crud_failed_to_create_instance = Failed to create a new data.
errors.crud_failed_to_create_crud_table = Failed to create a new data. ({0})
errors.crud_failed_to_update_crud_table=Failed to update the data. ({0})
errors.crud_failed_to_delete_crud_table=Failed to delete the data. ({0})

        testServer = System.getProperty("rdma.test.server");
        String portStr = System.getProperty("rdma.test.port", "445");
        testPort = Integer.parseInt(portStr);

        // Create RDMA-enabled context
        Properties props = new Properties();
        props.setProperty("jcifs.smb.client.useRDMA", "true");
        props.setProperty("jcifs.smb.client.rdmaProvider", "auto");