assertEquals(expected.length(), source.length());
  }

  public void testLengthIfKnown() throws IOException {
    Optional<Long> lengthIfKnown = source.lengthIfKnown();
    if (lengthIfKnown.isPresent()) {
      assertEquals(expected.length(), (long) lengthIfKnown.get());
    }
  }

  public void testReadLines_withProcessor() throws IOException {
    List<String> list =
        source.readLines(

     */
    @Execute
    public JsonResponse<ApiResult> list(final OptionalThing<String> id) {
        final List<Map<String, Object>> list = getFileItems(id.isPresent() ? decodePath(id.get()) : null);
        try {
            return asJson(new ApiResult.ApiStorageResponse().items(list).status(ApiResult.Status.OK).result());
        } catch (final ResultOffsetExceededException e) {

    assertEquals(expected.length, source.size());
  }

  public void testSizeIfKnown() throws IOException {
    Optional<Long> sizeIfKnown = source.sizeIfKnown();
    if (sizeIfKnown.isPresent()) {
      assertEquals(expected.length, (long) sizeIfKnown.get());
    }
  }

  public void testContentEquals() throws IOException {
    assertTrue(
        source.contentEquals(

        boolean validArtifactId = Objects.equals(a1, a2);
        for (SourceRoot sr : getSourceRoots(project)) {
            Optional<String> moduleName = sr.module();
            if (moduleName.isPresent()) {
                isMultiModule = true;
                if (moduleName.get().equals(a2)) {
                    validArtifactId = true;
                    break;
                }
            }
        }

            @Override
            public void permissionChanged(OptionalThing<FessUserBean> userBean) {
                activityHelperCalled.set(true);
                assertTrue(userBean.isPresent());
                assertSame(ldapUser, userBean.get().getFessUser());
            }
        }, "activityHelper");

        String[] permissions = ldapUser.getPermissions();

        final Optional<OperationInfo> result = helper.getOperationInfo("reindex");

        assertTrue(result.isPresent());
        final OperationInfo info = result.get();
        assertEquals("reindex", info.name);
        assertEquals("node1@host1", info.instanceId);
        assertEquals("host1", info.hostname);

     * <p>
     * <strong>Implementation Note:</strong> The default implementation is equivalent to:
     * </p>
     * <pre>{@code
     * Optional<Path> configured = targetPath();
     * if (configured.isPresent() && configured.get().isAbsolute()) {
     *     return configured.get();
     * }
     * Path outputDir = project.getOutputDirectory(scope());
     * return configured.map(outputDir::resolve).orElse(outputDir);

                            // 1. Child's phase start waits for parent's phase start
                            plan.step(p, BEFORE + n2).ifPresent(before::executeBefore);
                            // 2. Parent's phase completion waits for child's phase completion
                            plan.step(p, AFTER + n2).ifPresent(after::executeAfter);
                        });
                    }
                });
            });

	}
}

// Initialize KMS global variable after valiadating and loading the configuration.
// It depends on KMS env variables and global cli flags.
func handleKMSConfig() {
	present, err := kms.IsPresent()
	if err != nil {
		logger.Fatal(err, "Invalid KMS configuration specified")
	}
	if !present {
		return
	}

	KMS, err := kms.Connect(GlobalContext, &kms.ConnectionOptions{

     * @return The HTML response.
     */
    @Execute
    @Secured({ ROLE, ROLE + VIEW })
    public HtmlResponse list(final OptionalThing<Integer> pageNumber, final SearchForm form) {
        pageNumber.ifPresent(num -> {
            dataConfigPager.setCurrentPageNumber(pageNumber.get());
        }).orElse(() -> {
            dataConfigPager.setCurrentPageNumber(0);
        });