broadPropagation function

KairoState Function() broadPropagation(ReactiveFramework framework)

Implementation

KairoState Function() broadPropagation(ReactiveFramework framework) {
  final head = framework.signal(0);
  ISignal<int> last = head;
  final callCounter = Counter();

  for (int i = 0; i < 50; i++) {
    final current = framework.computed(() {
      return head.read() + i;
    });

    final current2 = framework.computed(() {
      return current.read() + 1;
    });

    framework.effect(() {
      current2.read();
      callCounter.count++;
    });

    last = current2;
  }

  return () {
    KairoState state = KairoState.success;

    framework.withBatch(() {
      head.write(1);
    });

    callCounter.count = 0;
    for (int i = 0; i < 50; i++) {
      framework.withBatch(() {
        head.write(i);
      });

      final count = (i + 1) * 50;
      if (last.read() != i + 50 || callCounter.count != count) {
        state = KairoState.fail;
      }
    }

    return state;
  };
}