Class LocalTest

future-java/src/test/java/io/trane/future/LocalTest.java:10–123

import org.junit.Test;

public class LocalTest {

  Local<Integer> l = Local.apply();

  @Test
  public void getEmpty() {
    assertEquals(Optional.empty(), l.get());
  }

  @Test
  public void getEmptyFreshThread() throws InterruptedException {
    AtomicReference<Optional<Integer>> result = new AtomicReference<>();
    Thread t = new Thread() {
      @Override
      public void run() {
        result.set(l.get());
      }
    };
    t.start();
    t.join();
    assertEquals(Optional.empty(), result.get());
  }

  @Test
  public void saveAndRestore() {
    l.update(1);
    assertEquals(Optional.of(1), l.get());

    Optional<?>[] saved = Local.save();

    l.update(2);
    assertEquals(Optional.of(2), l.get());

    Local.restore(saved);

    l.update(1);
    assertEquals(Optional.of(1), l.get());
  }

  @Test
  public void updateAndGet() {
    l.update(1);
    assertEquals(Optional.of(1), l.get());
  }

  @Test
  public void setAndGetDefined() {
    l.set(Optional.of(1));
    assertEquals(Optional.of(1), l.get());
  }

  @Test
  public void setAndGetEmpty() {
    l.set(Optional.empty());
    assertEquals(Optional.empty(), l.get());
  }

  @Test