// First read
        try (InputStream stream1 = cache.getInputStream()) {
            byte[] buffer1 = new byte[1024];
            int bytesRead1 = stream1.read(buffer1);
            assertEquals(testContent, new String(buffer1, 0, bytesRead1, "UTF-8"));
        }

        // Second read - should work independently
        try (InputStream stream2 = cache.getInputStream()) {
            byte[] buffer2 = new byte[1024];

        // Verify content in both files
        try (InputStream in = sourceFile.getInputStream()) {
            String sourceContent = new String(in.readAllBytes(), "UTF-8");
            assertEquals(content, sourceContent, "Source content should remain unchanged");
        }

        try (InputStream in = targetFile.getInputStream()) {
            String targetContent = new String(in.readAllBytes(), "UTF-8");

@Immutable
public interface XmlReaderRequest {

    @Nullable
    Path getPath();

    @Nullable
    Path getRootDirectory();

    @Nullable
    URL getURL();

    @Nullable
    InputStream getInputStream();

    @Nullable
    Reader getReader();

    @Nullable
    Transformer getTransformer();

    boolean isStrict();

    @Nullable
    String getModelId();

    @Nullable

    try {
      server
        .url("/a")
        .toUrl()
        .openConnection()
        .getInputStream()
      fail<Any>()
    } catch (expected: IOException) {
    }
    server
      .url("/b")
      .toUrl()
      .openConnection()
      .getInputStream() // Should succeed.
  }

  /**

 * try (ContentCache cache = new ContentCache(data)) {
 *     InputStream inputStream = cache.getInputStream();
 *     // Read from inputStream
 * }
 *
 * // File-based caching
 * File file = new File("example.txt");
 * try (ContentCache cache = new ContentCache(file)) {
 *     InputStream inputStream = cache.getInputStream();
 *     // Read from inputStream
 * }
 * }
 * </pre>
 *
 */

    try {
      server
        .url("/a")
        .toUrl()
        .openConnection()
        .getInputStream()
      fail<Unit>()
    } catch (expected: IOException) {
      // Expected.
    }
    server
      .url("/b")
      .toUrl()
      .openConnection()
      .getInputStream() // Should succeed.
  }

  @Test
  fun clearDispatcherQueue() {

        this.location = (location != null) ? location : "(memory)";
        this.hashCode = this.content.hashCode();
    }

    @Override
    public InputStream getInputStream() throws IOException {
        return new ByteArrayInputStream(content.getBytes(StandardCharsets.UTF_8));
    }

    @Override
    public String getLocation() {
        return location;
    }

    /**

     *
     * @return the NetBIOS address
     */
    public NbtAddress getNbtAddress() {
        return address;
    }

    @Override
    public InputStream getInputStream() throws IOException {
        return new SocketInputStream(super.getInputStream());
    }

    @Override
    public OutputStream getOutputStream() throws IOException {
        return new SocketOutputStream(super.getOutputStream());
    }

     * @return An input stream for reading the contents of the specified Zip file entry.
     */
    public static InputStream getInputStream(final ZipFile file, final ZipEntry entry) {
        assertArgumentNotNull("file", file);
        assertArgumentNotNull("entry", entry);

        try {
            return file.getInputStream(entry);
        } catch (final IOException e) {
            throw new IORuntimeException(e);
        }
    }

        return connection.getPermission();
    }

    @Override
    public InputStream getInputStream() throws IOException {
        try {
            handshake();
        } catch (final IOException ex) {}
        return connection.getInputStream();
    }

    @Override
    public OutputStream getOutputStream() throws IOException {
        try {
            connect();