return originalStream.read(b, off, len);
            }

            @Override
            public void close() throws IOException {
                closedFlag.set(true);
                originalStream.close();
            }

            @Override
            public int available() throws IOException {
                return originalStream.available();
            }

        return fileInputStream.available();
    }

    /**
     * Closes this input stream and releases any system resources associated with the stream.
     * @throws IOException if an I/O error occurs.
     */
    @Override
    public void close() throws IOException {
        try {
            fileInputStream.close();
        } finally {
            FileUtil.deleteInBackground(tempFile);
        }
    }

            failingFactory.destroyObject(pooledObject);
            fail("Should throw exception from close()");
        } catch (Exception e) {
            // Expected - exception should propagate from close()
            assertTrue(e.getMessage().contains("Intentional close failure"));
        }

        // Verify close was attempted
        assertTrue(component.isCloseCalled());
    }

    /**

        this.inputStream = inputStream;
    }

    /**
     * Overrides the close method to ignore the close operation.
     * The underlying input stream will not be closed.
     *
     * @throws IOException if an I/O error occurs (not thrown in this implementation)
     */
    @Override
    public void close() throws IOException {
        // inputStream.close();
    }

    /**

 * </ul>
 *
 * <p>Methods:</p>
 * <ul>
 *   <li>{@code getFile()} - Marks the file as retrieved and returns the file.</li>
 *   <li>{@code close()} - Closes the stream and deletes the temporary file if it is not needed.</li>
 * </ul>
 */
public class ContentOutputStream extends DeferredFileOutputStream {

    /**
     * The logger for this class.
     */

            BinaryCompatibilityRepository(SourcesRepository(sourceRoots, compilationClasspath))
    }

    @VisibleForTesting
    fun emptyCaches() =
        sources.close()

    override fun close() =
        emptyCaches()

    fun isOverride(method: JApiMethod): Boolean =
        apiSourceFileFor(method).let { apiSourceFile ->
            when (apiSourceFile) {

        this.clientMap = clientMap;
    }

    /**
     * Closes all clients in the factory.
     */
    @Override
    public void close() {
        clientMap.values().stream().distinct().forEach(client -> {
            try {
                client.close();
            } catch (final Exception e) {
                logger.warn("Failed to close {}.", client.getClass().getCanonicalName(), e);
            }
        });

    assert file.size == 4
    await file.write(b" and more data!")
    assert await file.read() == b""
    assert file.size == 19
    await file.seek(0)
    assert await file.read() == b"data and more data!"

                // Continue with destruction even if listener fails
            }
        }

        // Close the object if it implements AutoCloseable or Closeable
        final T obj = p.getObject();
        if (obj instanceof AutoCloseable) {
            try {
                ((AutoCloseable) obj).close();
            } catch (final Exception e) {

     * Checks if storage is properly configured and accessible.
     *
     * @return true if storage is available
     */
    boolean isAvailable();

    /**
     * Closes the client and releases resources.
     */
    @Override
    void close();