geersch

// Compose a projection. 
// - Tell what type of state the projection maintains (List<WizardActivity>)
var projection = Compose<List<WizardActivity>>.Projection()
	.Initialize(() => new List<WizardActivity>()) // How do you want to initialize the state when you run the projection?
	// When a wizard was started we want to know about it.
	.When<WizardStarted>((@event, state) =>
	{
		var activity = new WizardActivity(@event.CorrelationId.Value, @event.TimeStamp);
		if (!state.Contains(activity))
			state.Add(activity);

geersch

import { blue, bold, cyan, green, yellow } from 'kleur';
import { clear, log } from 'node:console';
import { createReadStream } from 'node:fs';
import { join } from 'node:path';
import { PassThrough, Readable } from 'node:stream';

clear();

// const path = join(__dirname, '../files/13KB.pdf');
// const path = join(__dirname, '../files/1MB.pdf');