import io.vavr.control.Try; //导入依赖的package包/类
@Test
public void testReplaceColumn() {
    DataTable oldTable = createDataTable();

    IDataColumn newCol = createDoubleColumn();
    Try<DataTable> newTable = oldTable.columns().replace("IntegerCol", newCol);

    assertTrue(newTable.isSuccess());
    assertTrue(oldTable.columns().count() == 3);
    assertTrue(newTable.get().columns().count() == 3);

    // Check the correct column was replaced.
    assertTrue(newTable.get().column(0).name().equals("StringCol"));
    assertTrue(newTable.get().column(1).name().equals("DoubleCol"));
    assertTrue(newTable.get().column(2).name().equals("BooleanCol"));
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Test
public void listFiles_existing_folder() throws IOException {
    final Try<Path> pathUtilsTestFolder = Paths.getPathForResource(PATH_UTIL_TESTS_FOLDER);
    assertThat(pathUtilsTestFolder.isSuccess()).isTrue();

    final List<Path> files = Paths.listFiles(pathUtilsTestFolder.get());
    assertThat(files.size()).isEqualTo(2);

    final List<String> fileNames = files.stream()
        .map(Path::getFileName)
        .map(Path::toString)
        .collect(Collectors.toList());

    assertThat(fileNames).containsExactlyInAnyOrder(
        EXISTING_FILE_NAME,
        EXISTING_ANOTHER_FILE_NAME
    );
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Test
public void testInsertColumn() {
    DataTable oldTable = createDataTable();

    IDataColumn newCol = createDoubleColumn();
    Try<DataTable> newTable = oldTable.columns().insert(0, newCol);

    assertTrue(newTable.isSuccess());
    assertTrue(oldTable.columns().count() == 3);
    assertTrue(newTable.get().columns().count() == 4);

    // Check the column was inserted in the correct place.
    assertTrue(newTable.get().column(0).name().equals("DoubleCol"));
    assertTrue(newTable.get().column(1).name().equals("StringCol"));
    assertTrue(newTable.get().column(2).name().equals("IntegerCol"));
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Override
public final Try<T> value() {
    if(results.isEmpty()) {
        throw new IllegalStateException("Attempt to combine an empty set");
    }
    return results.map(Result::value)
            .reduce((t1, t2) -> {
                if(t1.isFailure() || t2.isFailure()) {
                    return Try.failure(
                        new RuntimeException(
                            String.join("\r\n", issues())
                        )
                    );
                }
                return Try.success(
                    combineOperator.apply(t1.get(), t2.get())
                );
            });
}
 

import io.vavr.control.Try; //导入依赖的package包/类
public static Try<Integer> getAvailablePort() {
    synchronized (ASSIGNED_PORTS_MONITOR) {
        return Try.of(() -> {
            int hostPort;
            do {
                final ServerSocket serverSocket = new ServerSocket(0);
                hostPort = serverSocket.getLocalPort();
                serverSocket.close();
            } while (assignedPorts.contains(hostPort));

            assignedPorts = assignedPorts.add(hostPort);

            return hostPort;
        });
    }
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Test
public void testSimpleQuickSort() {

    DataTable table = DataTableBuilder
            .create("NewTable")
            .withColumn(Integer.class, "IntCol", List.of(3, 20, 4, 18, 0, -30, 100))
            .build().get();

    Try<DataView> view = table.quickSort("IntCol", SortOrder.Descending);

    assertTrue(view.isSuccess());

    // Check IntCol values are in descending order.
    assertTrue(view.get().row(0).getAs(Integer.class, "IntCol") == 100);
    assertTrue(view.get().row(1).getAs(Integer.class, "IntCol") == 20);
    assertTrue(view.get().row(2).getAs(Integer.class, "IntCol") == 18);
    assertTrue(view.get().row(3).getAs(Integer.class, "IntCol") == 4);
    assertTrue(view.get().row(4).getAs(Integer.class, "IntCol") == 3);
    assertTrue(view.get().row(5).getAs(Integer.class, "IntCol") == 0);
    assertTrue(view.get().row(6).getAs(Integer.class, "IntCol") == -30);
}
 

import io.vavr.control.Try; //导入依赖的package包/类
private Try<DataTable> actionByColumnName(String columnName, Function<Integer, Try<DataTable>> action) {
    Integer idx = columnIdxByName(columnName);

    return idx < 0
            ? error("Column not found with name " + columnName)
            : action.apply(idx);
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Override
protected String loadStylesheet() {
    return Try.of(() -> stylesheetFilePath)
        .mapTry(Files::readAllBytes)
        .map(String::new)
        .getOrElseThrow((Function<? super Throwable, RuntimeException>) RuntimeException::new);
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Test
public void testDataReplaceRowValues() {
    DataTable table = createDataTable();

    Try<DataTable> result = table.rows().replaceValues(2, "ZZ", 100, true);

    assertTrue(result.isSuccess());
    testDataTableOnReplace(result.get());
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Test
public void testTryNotNullValidArgument() {
    Try<Integer> result = Guard.tryNotNull(12345, "MyArgName");

    assertTrue(result.isSuccess());
    assertTrue(result.get() == 12345);
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Test
public void testDataInsertRowWithInvalidIndex() {
    DataTable table = createDataTable();

    // Insert data at an invalid index.
    Object[] rowValues = { "ZZ", 100, true };
    Try<DataTable> result = table.rows().insert(200, rowValues);

    assertTrue(result.isFailure());
    assertTrue(result.getCause() instanceof IndexOutOfBoundsException);
}
 

import io.vavr.control.Try; //导入依赖的package包/类
/**
 * Returns the value of a particular row column as a specific type.
 * This method performs bounds checks and type checks. Any errors
 * will return a Try.failure.
 *
 * @param type The data type.
 * @param colName The name of the column.
 * @param <T> The value type.
 * @return Returns the value at the specified index.
 */
public <T> Try<T> tryGetAs(Class<T> type, String colName) {

    // Get the column as it's typed version.
    Try<DataColumn<T>> col = this.table.columns()
            .tryGet(colName)
            .flatMap(c -> c.asType(type));

    return col.isFailure()
            ? Try.failure(col.getCause())
            : Try.success(col.get().valueAt(this.rowIdx));
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Override
public <T extends Node> Try<T> loadNode(final FxmlNode nodeInfo, final Class<T> nodeClass) {
    return this.loadNodeImpl(
        this.getSingleStageFxmlLoader(nodeInfo),
        nodeInfo,
        nodeClass
    );
}
 

import io.vavr.control.Try; //导入依赖的package包/类
/**
 * This method acts just like {@link #loadNode(FxmlNode)} but with no
 * autoconfiguration of controller binding and stylesheet application.
 */
private <T extends Node> Try<T> loadNodeImpl(final FxmlLoader fxmlLoader, final FxmlNode fxmlNode, final Class<T> clazz) {
    final String filePath = this.filePath(fxmlNode);
    fxmlLoader.setLocation(getUrlForResource(filePath));
    final Try<T> loadResult = Try.of(fxmlLoader::load).map(clazz::cast);

    loadResult.onSuccess(fxmlLoader::onSuccess).onFailure(fxmlLoader::onFailure);

    return this.applyStylesheetIfNeeded(
        fxmlNode,
        loadResult
    );
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Test
public void testValidToTypedColumn() {
    IDataColumn column = createIntegerColumn();
    Try<DataColumn<Integer>> typedCol = column.asType(Integer.class);

    assertTrue(typedCol.isSuccess());
    assertTrue(typedCol.get().valueAt(1) == 7);
}
 

import io.vavr.control.Try; //导入依赖的package包/类
private FxmlLoader getSingleStageFxmlLoader(final FxmlNode node) {
    final FxmlLoader loader = this.context.getBean(FxmlLoader.class);
    final Try<FxmlController> instanceLoadingResult = this.makeControllerForNode(node);
    instanceLoadingResult.peek(instance -> {
        loader.setControllerFactory(clazz -> instance);
        loader.setOnSuccess(elem -> this.controllerManager.registerSingle(node, instance));
        loader.setOnFailure(cause -> LOG.error("Could not load node {}", node, cause));
    });
    return loader;
}
 

import io.vavr.control.Try; //导入依赖的package包/类
private FxmlLoader getMultiStageFxmlLoader(final FxmlNode node, final Object selector) {
    final FxmlLoader loader = this.context.getBean(FxmlLoader.class);
    final Try<FxmlController> instanceLoadingResult = this.makeControllerForNode(node);
    instanceLoadingResult.peek(instance -> {
        loader.setControllerFactory(clazz -> instance);
        loader.setOnSuccess(elem -> this.controllerManager.registerMultiple(node, selector, instance));
        loader.setOnFailure(cause -> LOG.error("Could not load node {}", node, cause));
    });
    return loader;
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Test
public void testDataRowGetCheckedItemAsTypedByColName() {
    DataTable table = createDataTable();
    DataRow row = table.row(1);
    Try<Integer> itemData = row.tryGetAs(Integer.class, "IntegerCol");

    assertTrue(itemData.isSuccess());
    assertTrue(itemData.get() == 7);
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Test
public void testDataRowGetItemAsUntypedByInvalidColIndex() {
    DataTable table = createDataTable();
    DataRow row = table.row(1);
    Try<Object> itemData = row.get(10000);

    assertTrue(itemData.isFailure());
    assertTrue(itemData.getCause().getMessage().equals("Column index out of bounds"));
}
 

import io.vavr.control.Try; //导入依赖的package包/类
@Test
public void testDataReplaceRowWithInvalidValueCount() {
    DataTable table = createDataTable();

    // Replace data where the number of values doesn't match the number of columns.
    Object[] rowValues = { "ZZ" };
    Try<DataTable> result = table.rows().replace(2, rowValues);

    assertTrue(result.isFailure());
    assertTrue(result.getCause().getMessage().equals("Number of values does not match number of columns."));
}