checkNotNull(unit);
      checkArgument(delay > 0, "delay must be > 0, found %s", delay);
      return new Scheduler() {
        @Override
        public Cancellable schedule(
            AbstractService service, ScheduledExecutorService executor, Runnable task) {
          return new FutureAsCancellable(
              executor.scheduleWithFixedDelay(task, initialDelay, delay, unit));
        }
      };
    }

    checkNotNull(callable);
    CloseableList closeables = new CloseableList();
    TrustedListenableFutureTask<V> task =
        TrustedListenableFutureTask.create(
            new AsyncCallable<V>() {
              @Override
              public ListenableFuture<V> call() throws Exception {
                CloseableList newCloseables = new CloseableList();
                try {

    private RuleManager ruleManager;

    @Override
    @SuppressWarnings("unchecked")
    protected void setUp() throws Exception {
        super.setUp();

        crawlerThread = new CrawlerThread();
        crawlerContext = new CrawlerContext();
        crawlerContext.sessionId = "test-session";
        crawlerContext.numOfThread = 1;
        crawlerContext.maxThreadCheckCount = 10;
        crawlerContext.maxDepth = 3;

/**
 * OpenID Connect credential implementation.
 */
public class OpenIdConnectCredential implements LoginCredential, FessCredential {

    private final Map<String, Object> attributes;

    /**
     * Creates a new OpenID Connect credential.
     *
     * @param attributes the attributes from OpenID Connect provider
     */
    public OpenIdConnectCredential(final Map<String, Object> attributes) {
        this.attributes = attributes;

                    assertThrows(MalformedURLException.class, () -> new SmbNamedPipe(url, SmbPipeResource.PIPE_TYPE_RDWR, ctx()));
            assertEquals("Named pipes are only valid on IPC$", ex.getMessage());
        }

        @Test
        @DisplayName("Null context throws NPE (invalid input)")
        void nullContextThrows() {
            assertThrows(NullPointerException.class, () -> new SmbNamedPipe("smb://server/IPC$/foo", 0, null));
        }

                k3(),
                (k, v) -> {
                  throw new AssertionFailedError();
                }));
    expectUnchanged();
  }

  @MapFeature.Require(SUPPORTS_PUT)
  @CollectionSize.Require(absent = ZERO)
  public void testComputeIfPresent_supportedPresent() {
    assertEquals(
        "computeIfPresent(present, function) should return new value",
        v3(),
        getMap()
            .computeIfPresent(

    public LegacyLocalRepositoryManager(File basedir) {
        this.repository = new LocalRepository(basedir.getAbsoluteFile(), "legacy");
    }

    @Override
    public LocalRepository getRepository() {
        return repository;
    }

    @Override
    public String getPathForLocalArtifact(Artifact artifact) {
        StringBuilder path = new StringBuilder(128);

        path.append(artifact.getGroupId()).append('/');

    LegacyLocalRepositoryManager(File basedir) {
        this.repository = new LocalRepository(basedir.getAbsoluteFile(), "legacy");
    }

    @Override
    public LocalRepository getRepository() {
        return repository;
    }

    @Override
    public String getPathForLocalArtifact(Artifact artifact) {
        StringBuilder path = new StringBuilder(128);

        path.append(artifact.getGroupId()).append('/');

            logger.debug("[updateMemberOf] Starting for user: {}", user.getName());
        }

        final List<String> groupList = new ArrayList<>();
        final List<String> roleList = new ArrayList<>();
        final List<String> groupIdsForParentLookup = new ArrayList<>();

        final List<String> defaultGroups = getDefaultGroupList();
        final List<String> defaultRoles = getDefaultRoleList();

      if (index == null) {
        throw new IllegalArgumentException(
            getKeyRole() + " " + key + " not in " + keyIndex.keySet());
      }
      return setValue(index, value);
    }

    @Override
    public @Nullable V remove(@Nullable Object key) {
      throw new UnsupportedOperationException();
    }

    @Override
    public void clear() {
      throw new UnsupportedOperationException();
    }