while (!canceled && reader.processNextEvent()) {
          }
        }
      } catch (e: Exception) {
        val exception =
          when {
            canceled -> IOException("canceled", e)
            else -> e
          }
        listener.onFailure(this, exception, response)
        return
      }
      if (canceled) {
        listener.onFailure(this, IOException("canceled"), response)

    public void fire(
            ExecutionEvent.Type eventType, MavenSession session, MojoExecution mojoExecution, Exception exception) {
        ExecutionListener listener = session.getRequest().getExecutionListener();

        if (listener != null) {
            ExecutionEvent event = new DefaultExecutionEvent(eventType, session, mojoExecution, exception);

            switch (eventType) {
                case ProjectDiscoveryStarted:

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.core.exception;

/**
 * Exception that wraps {@link IndexOutOfBoundsException}.
 *
 * @author wyukawa
 */
public class ClIndexOutOfBoundsException extends IndexOutOfBoundsException {

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

/**
 * This class represents a custom exception for the suggester component.
 * It extends the {@link RuntimeException} class and provides constructors
 * to create an exception instance with a message, a cause, or both.
 *
 * <p>Usage examples:</p>
 * <pre>

      builder.addInterceptor(interceptor)
    }
    client = builder.build()
  }

  /** Catches exceptions that are otherwise headed for the uncaught exception handler.  */
  private class ExceptionCatchingExecutor : ThreadPoolExecutor(1, 1, 0, TimeUnit.SECONDS, SynchronousQueue()) {
    private val exceptions: BlockingQueue<Exception> = LinkedBlockingQueue()

    override fun execute(runnable: Runnable) {
      super.execute {

  };

  private final OkHttpClient client;

  public RewriteResponseCacheControl(File cacheDirectory) throws Exception {
    Cache cache = new Cache(cacheDirectory, 1024 * 1024);
    cache.evictAll();

    client = new OkHttpClient.Builder()
        .cache(cache)
        .build();
  }

  public void run() throws Exception {
    for (int i = 0; i < 5; i++) {
      System.out.println("    Request: " + i);

 */
@Deprecated(since = "4.0.0")
public class InvalidRepositoryException extends Exception {

    /**
     * The repository that raised this error, can be {@code null}.
     */
    private Repository repository;

    /**
     * Creates a new exception with specified detail message and cause for the given repository.
     *
     * @param message The detail message, may be {@code null}.

import org.codelibs.core.lang.StringUtil;

/**
 * @author higa
 *
 */
public class InputStreamUtilTest extends TestCase {

    /**
     * @throws Exception
     */
    public void testGetBytes() throws Exception {
        final InputStream is = ResourceUtil.getResourceAsStream(StringUtil.replace(getClass().getName(), ".", "/") + ".class");
        try {

        assertNotNull(dfsRootEnum.totalentries);
    }

    @Test
    @DisplayName("getEntries should return empty array when no DFS roots exist")
    void testGetEntries_emptyArray() throws Exception {
        // Create empty DfsEnumArray200
        netdfs.DfsEnumArray200 emptyArray = new netdfs.DfsEnumArray200();
        emptyArray.count = 0;
        emptyArray.s = new netdfs.DfsInfo200[0];

import org.codelibs.fess.crawler.entity.ResponseData;
import org.codelibs.fess.crawler.entity.ResultData;
import org.codelibs.fess.crawler.entity.TestEntity;
import org.codelibs.fess.crawler.exception.CrawlerSystemException;
import org.dbflute.utflute.core.PlainTestCase;

/**
 * @author shinsuke
 *
 */
public class XpathTransformerTest extends PlainTestCase {
    public XpathTransformer xpathTransformer;