assertNotNull(data.getResponseBody());

        try (InputStream is = data.getResponseBody()) {
            byte[] buffer = new byte[content.length];
            int bytesRead = is.read(buffer);
            assertEquals(content.length, bytesRead);
            assertTrue(Arrays.equals(content, buffer));
        } catch (IOException e) {
            fail("IOException should not occur: " + e.getMessage());
        }
    }

            }
            throw e
          }

          if (bytesRead == -1L) {
            if (!cacheRequestClosed) {
              cacheRequestClosed = true
              cacheBody.close() // The cache response is complete!
            }
            return -1
          }

          sink.copyTo(cacheBody.buffer, sink.size - bytesRead, bytesRead)
          cacheBody.emitCompleteSegments()
          return bytesRead

        IgnoreCloseInputStream stream = new IgnoreCloseInputStream(underlyingStream);

        byte[] buffer = new byte[5];
        int bytesRead = stream.read(buffer);

        assertEquals(5, bytesRead);
        assertEquals("Hello", new String(buffer));
    }

    public void test_readBytesWithOffset_delegatesToUnderlying() throws IOException {

        // Given
        SmbComClose smbComClose = new SmbComClose(config, 1, 1L);
        byte[] buffer = new byte[0];

        // When
        int bytesRead = smbComClose.readParameterWordsWireFormat(buffer, 0);

        // Then
        assertEquals(0, bytesRead);
    }

    /**
     * Test method for {@link jcifs.internal.smb1.com.SmbComClose#readBytesWireFormat(byte[], int)}.
     */
    @Test

            writeInt2(dataOffset, buffer, bufferIndex);
        }

        @Test
        public void testReadParameterWordsWireFormat() {
            int bytesRead = response.readParameterWordsWireFormat(buffer, 0);

            assertEquals(20, bytesRead);
            assertEquals(dataCompactionMode, response.dataCompactionMode);
            assertEquals(dataLength, response.dataLength);

            SMBUtil.writeInt4(0x20, buffer, bufferIndex + 56); // FILE_ATTRIBUTE_ARCHIVE

            // When
            int bytesRead = response.readBytesWireFormat(buffer, bufferIndex);

            // Then
            assertEquals(60, bytesRead);
            assertEquals(SMB2_CLOSE_FLAG_POSTQUERY_ATTIB, response.getCloseFlags());

        writeInt4(1000, buffer, 8); // alloc
        writeInt4(500, buffer, 12); // free
        writeInt2(512, buffer, 16); // bytesPerSect

        int bytesRead = response.readDataWireFormat(buffer, 0, buffer.length);

        assertEquals(20, bytesRead, "Should read 20 bytes");
        assertNotNull(response.info, "Info object should not be null");

        // Create a buffer large enough to hold the read bytes
        byte[] buffer = new byte[6];
        int bytesRead = packet.readTrailerWireFormat(bais, buffer, 0);

        // Verify that 6 bytes were read, which is the expected length.
        assertEquals(6, bytesRead);
    }

    @Test
    void readTrailerWireFormatShouldThrowIOExceptionOnUnexpectedEOF() throws IOException {

            assertNotNull(stream);
            byte[] buffer = new byte[1024];
            int bytesRead = stream.read(buffer);
            assertEquals(data.length, bytesRead);
            assertArrayEquals(data, Arrays.copyOf(buffer, bytesRead));
        }
    }

    @Test
    public void testGetContentAsStreamWithoutCache() {
        CurlResponse response = new CurlResponse();

        byte[] buffer = new byte[16];
        SMBUtil.writeInt8(expectedValue, buffer, 0);

        // Decode
        int bytesRead = fileInfo.decode(buffer, 0, buffer.length);

        // Verify bytes read
        assertEquals(8, bytesRead);

        // Verify decoded value through toString
        assertTrue(fileInfo.toString().contains("endOfFile=" + expectedValue));
    }

    @Test