@Override
    public void forEach(Consumer<? super E> action) {
      checkNotNull(action);
      unfiltered.forEach(
          (E e) -> {
            if (predicate.test(e)) {
              action.accept(e);
            }
          });
    }

    @Override
    public boolean remove(@Nullable Object element) {
      return contains(element) && unfiltered.remove(element);
    }

    @Override

            final UpdateRequestBuilder builder =
                    ComponentUtil.getSearchEngineClient().prepareUpdate().setIndex(fessConfig.getIndexDocumentUpdateIndex()).setId(id);
            builderLambda.accept(builder);
            final UpdateResponse response = builder.execute().actionGet(fessConfig.getIndexIndexTimeout());
            return response.getResult() == Result.CREATED || response.getResult() == Result.UPDATED;

      }
    }
    return null;
  }

  @Override
  public void forEach(BiConsumer<? super K, ? super V> action) {
    checkNotNull(action);
    for (Entry<K, V> entry : entries) {
      action.accept(entry.getKey(), entry.getValue());
    }
  }

  @Override
  public int size() {
    return entries.length;
  }

  @Override
  boolean isPartialView() {
    return false;
  }

        ComponentUtil.getLdapManager()
                .validateGroupAttributes(Long.class, attributes,
                        s -> throwError.accept(messages -> messages.addErrorsPropertyTypeLong("attributes." + s, "attributes." + s)));
    }

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

        ComponentUtil.getLdapManager()
                .validateUserAttributes(Long.class, attributes,
                        s -> throwError.accept(messages -> messages.addErrorsPropertyTypeLong("attributes." + s, "attributes." + s)));
    }

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

                });
            }
            break;
        }
    }

    /**
     * Builds role-based access control query filters to restrict search results based on user roles.
     * This method applies role-based filtering to ensure users only see documents they have access to.
     *
     * @param queryContext the query context to modify

    @Override
    public void forEach(Consumer<? super V> action) {
      checkNotNull(action);
      for (ValueEntry<K, V> entry = firstEntry; entry != null; entry = entry.successorInValueSet) {
        action.accept(entry.getValue());
      }
    }

    @Override
    public int size() {
      return size;
    }

    @Override
    public boolean contains(@Nullable Object o) {

            capturedSessionId = sessionId;
            capturedCmdList = new ArrayList<>(cmdList);

            ProcessBuilder pb = new ProcessBuilder(cmdList);
            pbConsumer.accept(pb);
            capturedDirectory = pb.directory();
            capturedEnvironment = new HashMap<>(pb.environment());

            return new TestJobProcess(exitValue, processOutput);
        }
    }

                .stream(out -> {
                    try (final Writer writer = new BufferedWriter(new OutputStreamWriter(out.stream(), Constants.CHARSET_UTF_8))) {
                        writeCall.accept(writer);
                        writer.flush();
                    } catch (final Exception e) {
                        logger.warn("Failed to write {} to response.", id, e);
                    }
                });

			},
			{
				Name:     "bar.txt",
				Content:  []byte("bar\n"),
				Modified: time.Date(1979, 11, 30, 0, 0, 0, 0, time.UTC),
				Mode:     0666,
			},
		},
	},
	// Tests that we verify (and accept valid) crc32s on files
	// with crc32s in their file header (not in data descriptors)
	{
		Name: "crc32-not-streamed.zip",
		File: []ZipTestFile{
			{
				Name:     "foo.txt",
				Content:  []byte("foo\n"),