Run tests on effection v4

[taras]

Motivation

All extensions were migrated to v3 in #87, but we now want to be able to run tests on v4 which requires using import maps to switch dependencies.

Approach

1. run deno task generate-importmap to generate v4.importmap.json
2. run deno test --import-map v4.importmap.json -A to run tests

Tests with `spawn()` followed by `sleep(1)` pattern

1. https://github.com/thefrontside/effectionx/blob/99132644309867524b27b00191efcb204608bbb6/stream-helpers/batch.test.ts

Test: "creates a batch within maxTime when maxSize is never reached"

• effectionx/stream-helpers/batch.test.ts

  Lines 57 to 67 in 9913264

  	yield* spawn(() =>
  	forEach<readonly number[], void>(function* (batch) {
  	const now = performance.now();
  	windows.push(now - last);
  	last = now;
  	batches.push(batch);
  	}, stream)
  	);
  	yield* sleep(1);

Test: "creates a batch within maxSize in maxTime window"

• effectionx/stream-helpers/batch.test.ts

  Lines 93 to 99 in 9913264

  	yield* spawn(() =>
  	forEach<readonly number[], void>(function* (batch) {
  	batches.push(batch);
  	}, stream)
  	);
  	yield* sleep(1);

2. https://github.com/thefrontside/effectionx/blob/99132644309867524b27b00191efcb204608bbb6/stream-helpers/tracker.test.ts

Test: "waits for all items to be processed"

• effectionx/stream-helpers/tracker.test.ts

  Lines 27 to 36 in 9913264

  	yield* spawn(function* () {
  	for (const item of yield* each(stream)) {
  	yield* sleep(10);
  	received.push(item);
  	tracker.markOne(item);
  	yield* each.next();
  	}
  	});
  	yield* sleep(1);

Test: "tracks batched items"

• effectionx/stream-helpers/tracker.test.ts

  Lines 70 to 78 in 9913264

  	yield* spawn(function* () {
  	for (const items of yield* each(stream)) {
  	received.push(items);
  	tracker.markMany(items);
  	yield* each.next();
  	}
  	});
  	yield* sleep(1);

3. https://github.com/thefrontside/effectionx/blob/99132644309867524b27b00191efcb204608bbb6/stream-helpers/test-helpers/faucet.test.ts

Test: "creates a faucet that can pour items"

• effectionx/stream-helpers/test-helpers/faucet.test.ts

  Lines 21 to 22 in 9913264

  	yield* spawn(function* () {
  	yield* sleep(1);

Test: "supports pouring with an operation"

• effectionx/stream-helpers/test-helpers/faucet.test.ts

  Lines 73 to 74 in 9913264

  	yield* spawn(function* () {
  	yield* sleep(1);

Test: "stops pouring when closed"

• effectionx/stream-helpers/test-helpers/faucet.test.ts

  Lines 102 to 103 in 9913264

  	yield* spawn(function* () {
  	yield* sleep(1);

4. https://github.com/thefrontside/effectionx/blob/99132644309867524b27b00191efcb204608bbb6/stream-helpers/for-each.test.ts

Test: "should invoke function for each item in the stream"

• effectionx/stream-helpers/for-each.test.ts

  Lines 22 to 23 in 9913264

  	yield* spawn(function* () {
  	yield* sleep(1);

Test: "should return the close value of the stream"

• effectionx/stream-helpers/for-each.test.ts

  Lines 44 to 45 in 9913264

  	yield* spawn(function* () {
  	yield* sleep(1);

5. https://github.com/thefrontside/effectionx/blob/99132644309867524b27b00191efcb204608bbb6/signals/helpers.test.ts

Test: "waits until the value of the stream matches the predicate"

• effectionx/signals/helpers.test.ts

  Lines 21 to 22 in 9913264

  	yield* spawn(function* () {
  	yield* sleep(1);

6. https://github.com/thefrontside/effectionx/blob/99132644309867524b27b00191efcb204608bbb6/signals/array.test.ts

Test: "does not send a value to the stream when the set value is the same as the current value"

• effectionx/signals/array.test.ts

  Lines 47 to 48 in 9913264

  	yield* spawn(function* () {
  	yield* sleep(1);

7. https://github.com/thefrontside/effectionx/blob/99132644309867524b27b00191efcb204608bbb6/stream-helpers/valve.test.ts

Test: "closes and opens the valve"

• effectionx/stream-helpers/valve.test.ts

  Lines 31 to 39 in 9913264

  	yield* spawn(function* () {
  	for (const value of yield* each(stream(faucet))) {
  	values.push(value);
  	yield* sleep(1);
  	yield* each.next();
  	}
  	});
  	yield* sleep(1);

8. https://github.com/thefrontside/effectionx/blob/99132644309867524b27b00191efcb204608bbb6/worker/worker.test.ts

Test: "shuts down gracefully"

• effectionx/worker/worker.test.ts

  Lines 75 to 89 in 9913264

  	let task = yield* spawn(function* () {
  	yield* useWorker(url, {
  	type: "module",
  	data: {
  	startFile,
  	endFile,
  	endText: "goodbye cruel world!",
  	} satisfies ShutdownWorkerParams,
  	});
  	yield* suspend();
  	});
  	let started = yield* timebox(10_000, function* () {
  	while (true) {
  	yield* sleep(1);

---

Total: 13 instances across 8 test files