Class FutureTest

future-java/src/test/java/io/trane/future/FutureTest.java:25–642

import org.junit.Test;

public class FutureTest {

  private <T> T get(Future<T> future) throws CheckedFutureException {
    return future.get(Duration.ofMillis(1));
  }

  private final ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
  private final Exception ex = new TestException();

  @After
  public void shutdownScheduler() {
    scheduler.shutdown();
  }

  /*** true ***/

  @Test
  public void trueConst() throws CheckedFutureException {
    assertEquals(true, get(Future.TRUE));
  }

  /*** false ***/

  @Test
  public void falseConst() throws CheckedFutureException {
    assertEquals(false, get(Future.FALSE));
  }

  /*** never ***/

  @Test
  public void never() {
    assertTrue(Future.never() instanceof NoFuture);
  }

  /*** apply ***/

  @Test
  public void applyValue() throws CheckedFutureException {
    Integer value = 1;
    Future<Integer> future = Future.apply(() -> value);
    assertEquals(value, get(future));
  }

  @Test(expected = ArithmeticException.class)
  public void applyException() throws CheckedFutureException {
    Future<Integer> future = Future.apply(() -> 1 / 0);
    get(future);
  }

  /*** flatApply ***/

  @Test
  public void flatApplyValue() throws CheckedFutureException {
    Integer value = 1;
    Future<Integer> future = Future.flatApply(() -> Future.value(value));
    assertEquals(value, get(future));
  }