39   private final Map<String, TestFuture> futures = new HashMap<>();
46   private TestFuture getOrCreate(String node) {  in getOrCreate()
47     TestFuture result = futures.get(node);  in getOrCreate()
49       result = new TestFuture(node);  in getOrCreate()
69     TestFuture future = futures.get(node);  in isCancelled()
95     for (TestFuture future : futures.values()) {  in assertNoStartedNodes()
100   private Only assertAboutNodes(Predicate<? super TestFuture> assertion, String... nodes) {  in assertAboutNodes()
101     ImmutableSet.Builder<TestFuture> builder = ImmutableSet.builder();  in assertAboutNodes()
103       TestFuture future = getOrCreate(node);  in assertAboutNodes()
116     private final ImmutableSet<TestFuture> expected;
117     private final Predicate<? super TestFuture> assertion;
119     Only(ImmutableSet<TestFuture> expected, Predicate<? super TestFuture> assertion) {  in Only()
129       for (TestFuture future : futures.values()) {  in only()
141   private static final class TestFuture extends AbstractFuture<String> {  class in ProducerTester
146     private TestFuture(String name) {  in TestFuture()  method in ProducerTester.TestFuture
151     TestFuture start() {  in start()
172   private static final Predicate<TestFuture> STARTED =
173       new Predicate<TestFuture>() {
175         public boolean test(TestFuture future) {
185   private static final Predicate<TestFuture> CANCELLED =
186       new Predicate<TestFuture>() {
188         public boolean test(TestFuture future) {