* for insertions.
   */
  static <E extends @Nullable Object> Set<E> preservesInsertionOrderOnAddsSet() {
    return CompactHashSet.create();
  }

  /**
   * Returns a new array of the given length with the same type as a reference array.
   *
   * @param reference any array of the desired type
   * @param length the length of the new array
   */

/**
 * An accumulator that selects the "top" {@code k} elements added to it, relative to a provided
 * comparator. "Top" can mean the greatest or the lowest elements, specified in the factory used to
 * create the {@code TopKSelector} instance.
 *
 * <p>If your input data is available as an {@link Iterable} or {@link Iterator}, prefer {@link
 * Ordering#leastOf(Iterable, int)}, which provides the same implementation with an interface

   */
  public static <E extends @Nullable Object> void assertMultisetIsUnmodifiable(
      Multiset<E> multiset, E sampleElement) {
    Multiset<E> copy = LinkedHashMultiset.create(multiset);
    assertCollectionsAreEquivalent(multiset, copy);

    // Multiset is a collection, so we can use all those tests.
    assertCollectionIsUnmodifiable(multiset, sampleElement);

                // TODO throw Exception in next release
                // create
                response = client.prepareIndex()
                        .setIndex(index)
                        .setSource(new DocMap(source))
                        .setRefreshPolicy(RefreshPolicy.IMMEDIATE)
                        .setOpType(OpType.CREATE)
                        .execute()

    @Execute
    public JsonResponse<ApiResult> post$setting(final String dictId, final CreateBody body) {
        body.dictId = dictId;
        validateApi(body, messages -> {});
        body.crudMode = CrudMode.CREATE;
        final KuromojiItem entity = createKuromojiItem(this, body, () -> {
            throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateInstance(GLOBAL));
            return null;

        this.id = id;
        this.inputs = inputs;
        this.output = output == null ? null : output.replace("\n", " ");
        Arrays.sort(inputs);

        if (id == 0) {
            // create
            newInputs = inputs;
            newOutput = output;
        }
    }

    /**
     * Returns the array of new input character sequences for update operations.

    // Channel binding
    private byte[] bindingHash;
    private boolean isPrimary;

    // Pending operations
    private final List<CommonServerMessageBlock> pendingOperations;

    /**
     * Create channel information
     *
     * @param channelId unique channel identifier
     * @param transport SMB transport for this channel
     * @param localInterface local network interface

        props.setProperty("jcifs.smb.client.soTimeout", "35000");

        config = new PropertyConfiguration(props);
    }

    @Test
    @DisplayName("Should create configuration from Properties")
    void testConfigurationCreation() throws CIFSException {
        // Then
        assertNotNull(config);
        assertEquals("testuser", config.getDefaultUsername());

        assertNull(unicodeStringFalse.buffer, "Buffer should be null for empty string");
    }

    @Test
    void testConstructorWithRpcUnicodeStringAndZterm() {
        // Create a dummy rpc.unicode_string
        rpc.unicode_string dummyRus = new rpc.unicode_string();
        dummyRus.length = 10;
        dummyRus.maximum_length = 20;
        dummyRus.buffer = new short[] { 'H', 'e', 'l', 'l', 'o' };

            ev.add(new DERTaggedObject(true, 0, new DERSequence(fields)));
            final ByteArrayOutputStream collector = new ByteArrayOutputStream();
            final ASN1OutputStream der = ASN1OutputStream.create(collector, ASN1Encoding.DER);
            final DERTaggedObject derApplicationSpecific = new DERTaggedObject(false, BERTags.APPLICATION, 0, new DERSequence(ev));
            der.writeObject(derApplicationSpecific);