assertEquals("\"intKey\":123", buf.toString());
    }

    // Test append method with Long value
    @Test
    public void test_append_longValue() {
        StringBuilder buf = new StringBuilder();
        Supplier<Object> supplier = () -> Long.valueOf(9876543210L);

        monitorTarget.append(buf, "longKey", supplier);
        assertEquals("\"longKey\":9876543210", buf.toString());

    }

    @Test
    public void test_exceptionWithLongMessage() {
        // Test with very long message
        int statusCode = 413;
        StringBuilder longMessage = new StringBuilder();
        for (int i = 0; i < 1000; i++) {
            longMessage.append("Very long error message content. ");
        }
        String message = longMessage.toString();

    }

    @Test
    public void test_constructor_withLongMessage() {
        // Test constructor with long message
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < 1000; i++) {
            sb.append("Long message content ");
        }
        String longMessage = sb.toString();

@app.post("/items/", summary="Create an item")
async def create_item(item: Item) -> Item:
    """
    Create an item with all the information:

    - **name**: each item must have a name
    - **description**: a long description
    - **price**: required
    - **tax**: if the item doesn't have tax, you can omit this
    - **tags**: a set of unique tag strings for this item
    \f
    :param item: User input.
    """

  }

internal infix fun Byte.and(mask: Int): Int = toInt() and mask

internal infix fun Short.and(mask: Int): Int = toInt() and mask

        dst[dstIndex + 3] = (byte) (val >> 24);
    }

    private void writeInt8(long val, byte[] dst, int dstIndex) {
        writeInt4((int) (val & 0xFFFFFFFFL), dst, dstIndex);
        writeInt4((int) (val >> 32), dst, dstIndex + 4);
    }

    private void writeTime(long t, byte[] dst, int dstIndex) {
        writeInt8(t, dst, dstIndex);
    }

        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

    public Long getVersionNo() {
        return asDocMeta().version();
    }

    public void setVersionNo(final Long version) {
        asDocMeta().version(version);
    }

    @Override
    public Integer getTimeToLive() {

    public String[] query;

    /** Maximum number of facet values to return */
    public Integer size;

    /** Minimum document count required for a facet value to be included */
    public Long minDocCount;

    /** Sort order for facet values (e.g., "count.desc", "term.asc") */
    public String sort;

    /** Value to use for documents that don't have the facet field */
    public String missing;

    private static final AtomicInteger keyGenerator = new AtomicInteger(2000);
    private static final AtomicLong addressCounter = new AtomicLong(0x10000000L);
    private static final Map<ByteBuffer, Long> bufferAddresses = new ConcurrentHashMap<>();

    // DiSNI objects - would be actual DiSNI types in real implementation
    private final Object endpoint; // RdmaActiveEndpoint

        final IndexResponse response = builder.execute().actionGet(indexTimeout);
        final long seqNo = response.getSeqNo();
        if (seqNo != SequenceNumbers.UNASSIGNED_SEQ_NO) {
            esEntity.asDocMeta().seqNo(seqNo);
        }
        final long primaryTerm = response.getPrimaryTerm();
        if (primaryTerm != SequenceNumbers.UNASSIGNED_PRIMARY_TERM) {