nope/test/testObservable.ts

import { NopeObservable } from "../lib/observables/nopeObservable";
import { generateBenchmarkFunction } from "../modules/funcs/generateBenchmarkFunction";

let max = 10000000;
const benchmark = generateBenchmarkFunction(max, "");
const observable = new NopeObservable<number>();

max = max * 10;
let i = 0;

const subscription = observable.subscribe({
  next: benchmark
});

while (i < max) {
  observable.setContent(i);
  i++;
}

subscription.unsubscribe();
i = 0;

observable.enhancedSubscription(benchmark);
while (i < max) {
  observable.observable.next(i);
  i++;
}