# TF_LoadLibrary/tf.load_op_library) register their ops and kernels with this
# shared object directly.
#
# For example, from Python tf.load_op_library loads a custom op library (via
# dlopen() on Linux), the library finds libtensorflow_framework.so (no
# filesystem search takes place, since libtensorflow_framework.so has already
# been loaded by pywrap_tensorflow) and registers its ops and kernels via

        // Initially not open (isStale returns false when handle is null, not true)
        assertFalse(target.isOpen());
        assertFalse(target.isStale());

        // After ensureOpen, handle valid -> open
        SmbFileHandleImpl fh = target.ensureOpen();
        assertSame(fileHandle, fh);
        assertTrue(target.isOpen());
        assertFalse(target.isStale());

    }

    /**
     * Tests whether the output stream is currently open.
     *
     * @return true if the stream is open, false otherwise
     */
    public boolean isOpen() {
        return file.isOpen();
    }

    void ensureOpen() throws IOException {
        // ensure file is open
        if (!file.isOpen()) {
            file.open(openFlags, access | SmbConstants.FILE_WRITE_DATA, SmbFile.ATTR_NORMAL, 0);

                SmbConstants.DEFAULT_SHARING);

        // When & Then
        assertTrue(outputStream.isOpen());

        when(mockFileHandle.isValid()).thenReturn(false);
        assertFalse(outputStream.isOpen());
    }

    @Test
    void testWriteAfterClose() throws IOException, CIFSException {
        // Given

    }

    /**
     * Tests whether the output stream is currently open.
     *
     * @return whether the stream is open
     */
    public boolean isOpen() {
        return this.handle != null && this.handle.isValid();
    }

    /**
     * Ensures that the file handle is open and returns it.
     *
     * @return the open file handle
     * @throws CIFSException if an error occurs opening the file

        /**
         * Verifies that the isOpen method returns true for an open handle.
         */
        @Test
        public void testIsOpen_ReturnsTrueWhenOpen() {
            when(smbPipeHandle.isOpen()).thenReturn(true);
            assertTrue(smbPipeHandle.isOpen(), "isOpen() should return true when the handle is open.");
        }

        /**
         * Verifies that the isOpen method returns false for a closed handle.

        super(handle.getPipe(), th, null, 0, 0, 0);
        this.handle = handle;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.smb.SmbFileOutputStream#isOpen()
     */
    @Override
    public boolean isOpen() {
        return this.handle.isOpen();
    }

    @Override
    protected synchronized SmbTreeHandleImpl ensureTreeConnected() throws CIFSException {
        return this.handle.ensureTreeConnected();
    }

    @DisplayName("isOpen delegates to handle.isOpen")
    void isOpen_delegates(boolean state) throws Exception {
        // Arrange
        SmbPipeOutputStream out = newStream();
        when(handle.isOpen()).thenReturn(state);

        // Act
        boolean result = out.isOpen();

        // Assert
        assertEquals(state, result, "isOpen should reflect handle state");

    }

    public String getUncPath() {
        return this.uncPath;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.SmbPipeHandle#isOpen()
     */
    @Override
    public boolean isOpen() {
        return this.open && this.handle != null && this.handle.isValid();
    }

    /**
     *
     * {@inheritDoc}
     *
     * @see jcifs.smb.SmbPipeHandleInternal#getSessionKey()

    this.delegate = delegate
  }

  override fun onOpen(
    webSocket: WebSocket,
    response: Response,
  ) {
    Platform.get().log("[WS $name] onOpen", Platform.INFO, null)
    val delegate = delegate
    if (delegate != null) {
      this.delegate = null
      delegate.onOpen(webSocket, response)
    } else {
      events.add(Open(webSocket, response))
    }
  }

  override fun onMessage(