Simple Rxjs subject load tester

gistfile1.txt

const subjectCount = 500000;
const subjects = [];
for(let i = 0 ; i < subjectCount; i++) {
	subjects[i] = new Subject();
	subjects[i].subscribe(
		(next) => console.log('next ' + i + ' ' + next),
		(error) => console.log('error ' + i + ' ' + error),
		() => console.log('close ' + i)
	);
}

let count = 0;
setInterval(
	() => {
		subjects[Math.floor(Math.random() * subjectCount)].next(count++);
	},
	10
);