2020-08-25 22:11:26 +00:00
|
|
|
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
|
|
|
|
|
|
|
|
let subscription = observable.subscribe({
|
|
|
|
next: benchmark
|
|
|
|
})
|
|
|
|
|
|
|
|
while (i < max) {
|
2020-08-30 10:00:31 +00:00
|
|
|
observable.setContent(i);
|
2020-08-25 22:11:26 +00:00
|
|
|
i++;
|
|
|
|
}
|
|
|
|
|
|
|
|
subscription.unsubscribe();
|
|
|
|
i = 0;
|
|
|
|
|
|
|
|
observable.enhancedSubscription(benchmark);
|
|
|
|
while (i < max) {
|
|
|
|
observable.observable.next(i);
|
|
|
|
i++;
|
|
|
|
}
|