private final Process process;

        /** The timeout duration in milliseconds. */
        private final long timeout;

        /** Flag indicating if the process has finished. */
        private boolean finished = false;

        /** Flag indicating if the process has been terminated. */
        private boolean teminated = false;

        /**
         * Constructor for MonitorThread.

    /** The total number of pages based on the page size and total record count. */
    protected int allPageCount;

    /** Flag indicating whether there is a next page available. */
    protected boolean existNextPage;

    /** Flag indicating whether there is a previous page available. */
    protected boolean existPrevPage;

    /** The record number of the first record on the current page (1-based). */

      if (outFinished) {
        this.sink.finished = true
        notifyAll() // Because doReadTimeout() may have changed.
      }
    }

    // Only DATA frames are subject to flow-control. Transmit the HEADER frame if the connection
    // flow-control window is fully depleted.
    if (!flushHeaders) {
      withLock {
        flushHeaders = (connection.writeBytesTotal >= connection.writeBytesMaximum)
      }
    }

        String logoutUrl = "https://sso.example.com/logout";
        authenticator.setLogoutUrl(logoutUrl);

        // Execute authentication flow
        LoginCredential loginResult = authenticator.getLoginCredential();
        assertNotNull(loginResult);

        TestLoginCredentialResolver resolver = new TestLoginCredentialResolver();

            true
          } else {
            false
          }
      }
      else -> {
        if (reservedFlag1) throw ProtocolException("Unexpected rsv1 flag")
      }
    }

    val reservedFlag2 = b0 and B0_FLAG_RSV2 != 0
    if (reservedFlag2) throw ProtocolException("Unexpected rsv2 flag")

    val reservedFlag3 = b0 and B0_FLAG_RSV3 != 0

  static final Iterable<Integer> ALL_INTEGER_CANDIDATES;

  static {
    ImmutableSet.Builder<Integer> intValues = ImmutableSet.builder();
    // Add boundary values manually to avoid over/under flow (this covers 2^N for 0 and 31).
    intValues.add(Integer.MAX_VALUE - 1, Integer.MAX_VALUE);
    // Add values up to 40. This covers cases like "square of a prime" and such.
    for (int i = 1; i <= 40; i++) {

        /** The process to monitor and destroy. */
        private final Process p;

        /** The input stream thread reading process output. */
        private final InputStreamThread ist;

        /** Flag indicating if the destroyer has been executed. */
        private final AtomicBoolean executed = new AtomicBoolean(false);

        /** Timeout for process destruction in milliseconds. */
        private final long timeout;

    data.write("ca00".decodeHex()) // Empty pong, flag 1 set.
    assertFailsWith<ProtocolException> {
      clientReader.processNextFrame()
    }.also { expected ->
      assertThat(expected.message).isEqualTo("Unexpected rsv1 flag")
    }
  }

  @Test fun reservedFlag1IsUnsupportedForControlFrames() {
    data.write("ca00".decodeHex()) // Empty pong, flag 1 set.
    assertFailsWith<ProtocolException> {

    @Resource
    protected SystemHelper systemHelper;

    /** Helper for document indexing operations */
    @Resource
    protected IndexingHelper indexingHelper;

    /** Flag indicating if crawling should be finished */
    protected boolean finishCrawling = false;

    /** Total execution time in milliseconds */
    protected long executeTime;

    protected String allRecordCountRelation;

    /** Total number of pages based on record count and page size. */
    protected int allPageCount;

    /** Flag indicating whether a next page exists. */
    protected boolean existNextPage;

    /** Flag indicating whether a previous page exists. */
    protected boolean existPrevPage;

    /** Starting record number for the current page. */