int getPathConsumed ();


    /**
     * @return the replacement path for this referal
     */
    String getPath ();


    /**
     * @return the expiration time of this entry
     */
    long getExpiration ();


    /**
     * 
     * @return pointer to next referral, points to self if there is no further referral
     */
    DfsReferralData next ();


    /**
     * @return the link

   * with a differently behaving {@code loader}. For example, a call that requests a short timeout
   * for an RPC may wait for a similar call that requests a long timeout, or a call by an
   * unprivileged user may return a resource accessible only to a privileged user making a similar
   * call. To prevent this problem, create a key object that includes all values that affect the

import java.util.ArrayDeque
import java.util.Deque
import okio.Buffer
import org.junit.jupiter.api.AfterEach
import org.junit.jupiter.api.Test

class ServerSentEventIteratorTest {
  /** Either [Event] or [Long] items for events and retry changes, respectively.  */
  private val callbacks: Deque<Any> = ArrayDeque()

  @AfterEach
  fun after() {
    assertThat(callbacks).isEmpty()
  }

  @Test
  fun multiline() {

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.entity;

import java.util.Map;

public interface SearchLogEvent {
    String getId();

    Long getVersionNo();

    Map<String, Object> toSource();

    String getEventType();

 */
package org.codelibs.fess.exception;

import jakarta.servlet.ServletException;

public class ServletRuntimeException extends RuntimeException {

    private static final long serialVersionUID = 1L;

    public ServletRuntimeException(final ServletException e) {
        super(e);
    }

 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 */
package mockwebserver3.internal

internal fun sleepNanos(nanos: Long) {
  val ms = nanos / 1_000_000L
  val ns = nanos - (ms * 1_000_000L)
  if (ms > 0L || nanos > 0) {
    Thread.sleep(ms, ns.toInt())
  }

 */
package org.codelibs.core.exception;

/**
 * Wrapped InterruptedException.
 *
 * @author shinsuke
 *
 */
public class InterruptedRuntimeException extends RuntimeException {

    private static final long serialVersionUID = 1L;

    public InterruptedRuntimeException(final InterruptedException e) {
        super(e);
    }

 */
package org.codelibs.fess.crawler.exception;

/**
 * @author shinsuke
 *
 */
public class CrawlerLoginFailureException extends CrawlerSystemException {
    private static final long serialVersionUID = 1L;

    public CrawlerLoginFailureException(final String message) {
        super(message);
    }

   * @param values a series of values, which will be converted to {@code double} values (this may
   *     cause loss of precision for longs of magnitude over 2^53 (slightly over 9e15))
   */
  public void addAll(long... values) {
    for (long value : values) {
      add(value);
    }
  }

  /**
   * Adds the given values to the dataset. The stream will be completely consumed by this method.
   *

/**
 * The Exception class throw by the {@link SettingsBuilder}.
 *
 * @since 4.0.0
 */
@Experimental
public class SettingsBuilderException extends MavenException {

    @Serial
    private static final long serialVersionUID = 4714858598345418083L;

    private final List<BuilderProblem> problems;

    /**
     * @param message the message to give
     * @param e the {@link Exception}
     */