Class PromiseTest

future-java/src/test/java/io/trane/future/PromiseTest.java:22–1192

import org.junit.Test;

public class PromiseTest {

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

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

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

  /*** apply ***/

  @Test
  public void apply() throws CheckedFutureException {
    Promise<Integer> p = Promise.apply();
    p.setValue(1);
    assertEquals(new Integer(1), get(p));
  }

  @Test
  public void applyWithLocal() {
    AtomicReference<Optional<Integer>> localValue = new AtomicReference<>();
    Local<Integer> l = Local.apply();
    l.update(1);
    Promise<Integer> p = Promise.apply();
    l.update(2);
    p.ensure(() -> localValue.set(l.get()));
    p.setValue(1);
    assertEquals(Optional.of(1), localValue.get());
  }

  @Test
  public void applyHandler() throws CheckedFutureException {
    AtomicReference<Throwable> interrupt = new AtomicReference<Throwable>();
    InterruptHandler handler = interrupt::set;
    Promise<Integer> p = Promise.apply(handler);
    p.raise(ex);
    assertEquals(ex, interrupt.get());
  }

  @Test
  public void applyHandlerWithLocal() {
    AtomicReference<Optional<Integer>> localValue = new AtomicReference<>();
    Local<Integer> l = Local.apply();
    l.update(1);
    Promise<Integer> p = Promise.apply((ex) -> {
    });
    l.update(2);
    p.ensure(() -> localValue.set(l.get()));
    p.setValue(1);
    assertEquals(Optional.of(1), localValue.get());
  }

  @Test