}

    /**
     * Get maximum fragmented size
     *
     * @return maximum fragmented size in bytes
     */
    public int getMaxFragmentedSize() {
        return maxFragmentedSize;
    }

    /**
     * Set maximum fragmented size
     *
     * @param maxFragmentedSize maximum fragmented size in bytes
     */

    }

    /**
     * Get maximum fragmented size
     *
     * @return maximum fragmented size in bytes
     */
    public int getMaxFragmentedSize() {
        return maxFragmentedSize;
    }

    /**
     * Set maximum fragmented size
     *
     * @param maxFragmentedSize maximum fragmented size in bytes
     */

  /**
   * Returns an {@link Escaper} instance that escapes strings so they can be safely included in a <a
   * href="https://url.spec.whatwg.org/#concept-url-fragment">URL fragment</a>. The returned escaper
   * escapes all non-ASCII characters.
   *
   * <p>When escaping a String, the following rules apply:
   *
   * <ul>

    }

    /**
     * Get the maximum size for fragmented operations
     *
     * @return maximum fragmented size in bytes
     */
    public int getMaxFragmentedSize() {
        return maxFragmentedSize;
    }

    /**
     * Set the maximum size for fragmented operations
     *
     * @param maxFragmentedSize maximum fragmented size in bytes
     */

	endPos := sw.pos + int64(len(b))
	for endPos > sw.pos && err == nil {
		var nf int // Bytes written in fragment
		dataStart, dataEnd := sw.sp[0].Offset, sw.sp[0].endOffset()
		if sw.pos < dataStart { // In a hole fragment
			bf := b[:min(int64(len(b)), dataStart-sw.pos)]
			nf, err = zeroWriter{}.Write(bf)
		} else { // In a data fragment
			bf := b[:min(int64(len(b)), dataEnd-sw.pos)]
			nf, err = sw.fw.Write(bf)
		}
		b = b[nf:]

            assertThrows(CIFSException.class, handle::getSessionKey);
        }
    }

    @Nested
    @DisplayName("Send/Receive Fragment Tests")
    class SendReceiveFragmentTests {

        @Test
        @DisplayName("Should send and receive fragment successfully")
        void testDoSendReceiveFragment_Success() throws Exception {
            DcerpcPipeHandle handle = createMockedDcerpcPipeHandle();

    }

    /**
     * Get the maximum size for fragmented operations
     *
     * @return maximum fragmented size in bytes
     */
    public int getMaxFragmentedSize() {
        return maxFragmentedSize;
    }

    /**
     * Set the maximum size for fragmented operations
     *
     * @param maxFragmentedSize maximum fragmented size in bytes
     */

      inflater.inflate("f240e30300".decodeHex())
    }
  }

  /**
   * Test for an [EOFException] caused by mishandling of fragmented buffers in web socket
   * compression. https://github.com/square/okhttp/issues/5965
   */
  @Test fun `inflate golden value in buffer that has been fragmented`() {
    val inflater = MessageInflater(false)
    val buffer = fragmentBuffer(Buffer().write("f248cdc9c957c8cc4bcb492cc9cccf530400".decodeHex()))

    /**
     * First fragment flag - indicates first fragment of a multi-fragment message
     */
    int DCERPC_FIRST_FRAG = 0x01; /* First fragment */
    /**
     * Last fragment flag - indicates last fragment of a multi-fragment message
     */
    int DCERPC_LAST_FRAG = 0x02; /* Last fragment */
    /**
     * Pending cancel flag - indicates cancel was pending at sender
     */

    /**
     * First fragment flag - indicates first fragment of a multi-fragment message
     */
    int DCERPC_FIRST_FRAG = 0x01; /* First fragment */
    /**
     * Last fragment flag - indicates last fragment of a multi-fragment message
     */
    int DCERPC_LAST_FRAG = 0x02; /* Last fragment */
    /**
     * Pending cancel flag - indicates cancel was pending at sender
     */