/** The OpenSearch client. */
    protected final Client client;
    /** The suggest settings. */
    protected final SuggestSettings suggestSettings;
    /** The reading converter. */
    protected final ReadingConverter readingConverter;
    /** The contents reading converter. */
    protected final ReadingConverter contentsReadingConverter;
    /** The normalizer. */
    protected final Normalizer normalizer;
    /** The analyzer. */

    }

    /** If [e] is non-null, this will return a non-null value. */
    fun complete(e: IOException?): IOException? {
      if (completed) return e
      completed = true
      // If the body is closed without reading any bytes send a responseBodyStart() now.
      if (e == null && invokeStartEvent) {
        invokeStartEvent = false
        eventListener.responseBodyStart(call)
      }
      return bodyComplete(

        }

        try {
            // In real implementation, this would perform RDMA read into the buffer
            // For skeleton implementation, simulate reading the requested amount
            int bytesToRead = Math.min(length, buffer.remaining());

            // Simulate RDMA read operation

    disconnectBeforeTrailers(Protocol.HTTP_1_1)
  }

  @Test
  fun disconnectBeforeTrailersHttp2() {
    disconnectBeforeTrailers(Protocol.HTTP_2)
  }

  /** Confirm we can get an [IOException] reading trailers. */
  private fun disconnectBeforeTrailers(protocol: Protocol) {
    enableProtocol(protocol)

    server.enqueue(
      MockResponse
        .Builder()
        .trailers(headersOf("t1", "v2"))

        assertEquals(0xFFFFFFFF, response.getCapabilities());
        assertEquals(0xFFFFFFFF, response.getMaximalAccess());
    }

    @Test
    @DisplayName("Should handle buffer too small for reading")
    void testBufferTooSmall() {
        // Given
        byte[] buffer = new byte[15]; // Too small for 16-byte structure
        SMBUtil.writeInt2(16, buffer, 0);

        // When & Then

labels.jobStatus=Status
labels.labelTypeIds=Labels
labels.lang=Language
labels.outputs=Outputs
labels.pos=Part-of-speech
labels.purgeJobLogDay=Delete old job logs
labels.purgeUserInfoDay=Delete old user logs
labels.reading=Reading
labels.roleTypeIds=Role IDs
labels.scriptData=Script
labels.scriptResult=Result
labels.scriptType=Execution Method
labels.segmentation=Segmentation
labels.startTime=Start Time
labels.target=Target

			transfi.TransitionTier = "MINIO-TIER"
			transfi.TransitionedObjName = mustGetUUID()
			xl.DeleteVersion(transfi)

			fi.SetTierFreeVersionID(mustGetUUID())
			// delete this version leading to a free version
			xl.DeleteVersion(fi)
			freeVersionIDs = append(freeVersionIDs, fi.TierFreeVersionID())
			allVersionIDs = append(allVersionIDs, fi.TierFreeVersionID())
		} else {
			versions = append(versions, fi)

      return null // Another edit is in progress.
    }

    if (entry != null && entry.lockingSourceCount != 0) {
      return null // We can't write this file because a reader is still reading it.
    }

    if (mostRecentTrimFailed || mostRecentRebuildFailed) {
      // The OS has become our enemy! If the trim job failed, it means we are storing more data than

        assertEquals(0L, response.getOffset(), "Offset should be initialized to 0");
    }

    /* ------------------------------------------------------------------ */
    /* 2. Parameter word reading - happy path & edge cases                */
    /* ------------------------------------------------------------------ */

    /**

        int dataBytes = transaction.writeDataWireFormat(buffer, 0);
        assertEquals(50, dataBytes, "writeDataWireFormat should return expected bytes");
    }

    @Test
    @DisplayName("Test parameter and data reading methods")
    void testReadMethods() {
        byte[] buffer = new byte[1024];

        int setupBytes = transaction.readSetupWireFormat(buffer, 0, 10);