import okhttp3.internal.http2.ErrorCode
import okhttp3.internal.http2.Http2Stream
import okio.buffer

/** Adapt OkHttp's internal [Http2Stream] type to the public [Stream] type. */
internal class RealStream(
  private val http2Stream: Http2Stream,
) : Stream {
  override val requestBody = http2Stream.getSource().buffer()
  override val responseBody = http2Stream.getSink().buffer()

  override fun cancel() {

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

/**
 * @author shinsuke
 *
 */
public class CrawlerSystemException extends RuntimeException {

    private static final long serialVersionUID = 1L;

    public CrawlerSystemException(final String message, final Throwable cause) {
        super(message, cause);
    }

    public CrawlerSystemException(final String message) {

    private final @Nullable ListenableFuture<? extends T>[] inputFutures;
    private volatile int delegateIndex = 0;

    private InCompletionOrderState(ListenableFuture<? extends T>[] inputFutures) {
      this.inputFutures = inputFutures;
      incompleteOutputCount = new AtomicInteger(inputFutures.length);
    }

    private void recordOutputCancellation(boolean interruptIfRunning) {

    // instance of ObjectOutputStream.

    // TODO(b/160980469): remove support for the old serialization format after some time
    private static final boolean USE_LEGACY_SERIALIZATION = true;

    private final Object keys;
    private final Object values;

    SerializedForm(ImmutableMap<K, V> map) {
      if (USE_LEGACY_SERIALIZATION) {
        Object[] keys = new Object[map.size()];

    @Resource
    protected AccessTokenHelper accessTokenHelper;

    @Resource
    protected ViewHelper viewHelper;

    @Resource
    private MessageManager messageManager;

    @Resource
    private RequestManager requestManager;

    // ===================================================================================

    //                                                                           Singleton
    //                                                                           =========
    private static final AccessTokenDbm _instance = new AccessTokenDbm();

    private AccessTokenDbm() {
    }

    public static AccessTokenDbm getInstance() {
        return _instance;
    }

@ElementTypesAreNonnullByDefault
@J2ktIncompatible
public final class ExecutionSequencer {

  private ExecutionSequencer() {}

  /** Creates a new instance. */
  public static ExecutionSequencer create() {
    return new ExecutionSequencer();
  }

  /** This reference acts as a pointer tracking the head of a linked list of ListenableFutures. */
  private final AtomicReference<ListenableFuture<@Nullable Void>> ref =

 * </p>
 *
 * @author higa
 * @see BeanDesc
 * @see DisposableUtil
 */
public abstract class BeanDescFactory {

    /** 初期化済みなら{@literal true} */
    private static volatile boolean initialized;

    /** {@link BeanDesc}のキャッシュ */
    private static final ConcurrentMap<Class<?>, BeanDesc> beanDescCache = newConcurrentHashMap(1024);

    static {
        initialize();
    }

    /**

import jcifs.Configuration;
import jcifs.internal.util.SMBUtil;
import jcifs.util.Hexdump;


/**
 * 
 */
public class NtTransNotifyChange extends SmbComNtTransaction {

    int fid;
    private int completionFilter;
    private boolean watchTree;


    /**
     * 
     * @param config
     * @param fid
     * @param completionFilter
     * @param watchTree
     */

 *
 * @since 4.0.0
 */
@Experimental
public class ModelBuilderException extends MavenException {

    @Serial
    private static final long serialVersionUID = -1865447022070650896L;

    private final ModelBuilderResult result;

    /**
     * Creates a new exception from the specified interim result and its associated problems.
     *