Class WaitQueueTest

future-java/src/test/java/io/trane/future/WaitQueueTest.java:9–208

import org.junit.Test;

public class WaitQueueTest {

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

  private <T> Continuation<T, T> newContinuation() {
    return new Continuation<T, T>() {
      @Override
      Future<T> apply(Future<T> result) {
        return result;
      }
    };
  }

  @Test
  public void addAndFlush1() throws CheckedFutureException {
    Continuation<Integer, Integer> c = newContinuation();
    
    c.flush(Future.value(1));
    
    assertEquals(new Integer(1), get(c));
  }

  @Test
  public void addAndFlush2() throws CheckedFutureException {
    Continuation<Integer, Integer> c1 = newContinuation();
    Continuation<Integer, Integer> c2 = newContinuation();

    c1.add(c2).flush(Future.value(1));
    
    assertEquals(new Integer(1), get(c1));
    assertEquals(new Integer(1), get(c2));
  }

  @Test
  public void addAndFlush3() throws CheckedFutureException {
    Continuation<Integer, Integer> c1 = newContinuation();
    Continuation<Integer, Integer> c2 = newContinuation();
    Continuation<Integer, Integer> c3 = newContinuation();
    
    c1.add(c2).add(c3).flush(Future.value(1));
    
    assertEquals(new Integer(1), get(c1));
    assertEquals(new Integer(1), get(c2));
    assertEquals(new Integer(1), get(c3));
  }

  @Test
  public void addAndFlush4() throws CheckedFutureException {
    Continuation<Integer, Integer> c1 = newContinuation();
    Continuation<Integer, Integer> c2 = newContinuation();
    Continuation<Integer, Integer> c3 = newContinuation();
    Continuation<Integer, Integer> c4 = newContinuation();
    
    c1.add(c2).add(c3).add(c4).flush(Future.value(1));
    
    assertEquals(new Integer(1), get(c1));