} finally {
      closer.close();
    }
  }

  /**
   * Concatenates multiple {@link CharSource} instances into a single source. Streams returned from
   * the source will contain the concatenated data from the streams of the underlying sources.
   *
   * <p>Only one underlying stream will be open at a time. Closing the concatenated stream will
   * close the open underlying stream.
   *

    } finally {
      closer.close();
    }
  }

  /**
   * Concatenates multiple {@link CharSource} instances into a single source. Streams returned from
   * the source will contain the concatenated data from the streams of the underlying sources.
   *
   * <p>Only one underlying stream will be open at a time. Closing the concatenated stream will
   * close the open underlying stream.
   *

            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());
    }

    /**

import jcifs.dcerpc.msrpc.lsarpc.LsarClose;

/**
 * Microsoft RPC LSA close handle request.
 * This class implements the LSARPC close handle operation.
 */
public class MsrpcLsarClose extends LsarClose {

    /**
     * Creates a new request to close an LSA policy handle.
     *
     * @param handle the policy handle to close
     */
    public MsrpcLsarClose(final policy_handle handle) {
        super(handle);

    }

    @Test
    @DisplayName("close calls release and decrements usage; double release throws")
    void closeAndReleaseBehavior() {
        // Validates usage counting and that an extra release() throws RuntimeCIFSException
        // First close -> usage 1 -> 0, triggers treeConnection.release()
        handle.close();
        verify(treeConnection, times(1)).release();

                AutoCloseable resource = holder.resourceRef.get();
                if (resource != null) {
                    try {
                        log.warn("Auto-closing abandoned resource: {} ({}, age: {} ms)", holder.resourceId, holder.resourceType,
                                holder.getAge());
                        resource.close();
                        holder.closed = true;

    System.out.println("MESSAGE: " + bytes.hex());
  }

  @Override public void onClosing(WebSocket webSocket, int code, String reason) {
    webSocket.close(1000, null);
    System.out.println("CLOSE: " + code + " " + reason);
  }

  @Override public void onFailure(WebSocket webSocket, Throwable t, Response response) {
    t.printStackTrace();
  }

  public static void main(String... args) {
    new WebSocketEcho().run();
  }

  public HashCode hash() {
    return hasher.hash();
  }

  // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior:
  // it silently ignores any exception thrown by flush(). Instead, just close the delegate stream.
  // It should flush itself if necessary.
  @Override
  public void close() throws IOException {
    out.close();
  }

package jcifs.smb1.dcerpc.msrpc;

/**
 * Microsoft RPC LSA close handle request.
 * This class implements the LSARPC close handle operation for closing
 * LSA policy handles when they are no longer needed.
 */
public class MsrpcLsarClose extends lsarpc.LsarClose {

    /**
     * Creates a new request to close an LSA policy handle.
     *
     * @param policyHandle the policy handle to close
     */

            verify(mockHandle, times(1)).close();
            verify(mockHandle, atLeastOnce()).acquire();
        }

        @Test
        @DisplayName("close() closes handle; does not close file when not unshared")
        void closeClosesHandle() throws Exception {
            SmbFileInputStream in = newStream();
            in.close();