try Effect 4 for thefrontside#981

Author: tim-smart

.gitignore

@@ -3,4 +3,5 @@
 
 # Local Netlify folder
 .netlify
-/build/
+/build/
+.direnv/

tasks/bench.ts

@@ -56,7 +56,7 @@ await main(function* (args) {
   for (let scenario of filter(scenarios, { include, exclude })) {
     tasks.push(
       yield* spawn(() =>
-        runBenchmark(scenario, { ...options, type: "benchmark" }),
+        runBenchmark(scenario, { ...options, type: "benchmark" })
       ),
     );
   }

tasks/bench/scenarios/effect.events.ts

@@ -1,45 +1,40 @@
-import { Effect, Fiber, Stream } from "npm:effect";
+import * as Effect from "https://raw.githubusercontent.com/Effect-TS/effect-smol/refs/heads/deno/src/Effect.ts";
+import * as Fiber from "https://raw.githubusercontent.com/Effect-TS/effect-smol/refs/heads/deno/src/Fiber.ts";
+import * as Stream from "https://raw.githubusercontent.com/Effect-TS/effect-smol/refs/heads/deno/src/Stream.ts";
 import { call } from "../../../mod.ts";
 import { scenario } from "./scenario.ts";
 
-await scenario(
-  "effect.events",
-  (depth) => call(() => Effect.runPromise(start(depth))),
-);
-
-export function start(depth: number) {
-  return Effect.gen(function* () {
-    const target = new EventTarget();
-    const task = yield* Effect.fork(recurse(target, depth));
-    for (let i = 0; i < 100; i++) {
-      yield* Effect.sleep(0);
-      target.dispatchEvent(new Event("foo"));
-    }
+export const start = Effect.fnUntraced(function* (depth: number) {
+  const target = new EventTarget();
+  const task = yield* Effect.fork(recurse(target, depth));
+  for (let i = 0; i < 100; i++) {
     yield* Effect.sleep(0);
-    yield* Fiber.interrupt(task);
-  });
-}
+    target.dispatchEvent(new Event("foo"));
+  }
+  yield* Effect.sleep(0);
+  yield* Fiber.interrupt(task);
+});
 
-function recurse(
+const recurse: (
   target: EventTarget,
   depth: number,
-): Effect.Effect<void, never, never> {
-  return Effect.gen(function* () {
-    const eventStream = Stream.fromEventListener(target, "foo");
+) => Effect.Effect<void> = Effect.fnUntraced(function* (target, depth) {
+  const eventStream = Stream.fromEventListener(target, "foo");
 
-    if (depth > 1) {
-      const subTarget = new EventTarget();
-      yield* Effect.fork(recurse(subTarget, depth - 1));
+  if (depth > 1) {
+    const subTarget = new EventTarget();
+    yield* Effect.fork(recurse(subTarget, depth - 1));
 
-      yield* eventStream.pipe(
-        Stream.runForEach(() => {
-          return Effect.sync(() => {
-            subTarget.dispatchEvent(new Event("foo"));
-          });
-        }),
-      );
-    } else {
-      yield* eventStream.pipe(Stream.runDrain);
-    }
-  });
-}
+    yield* Stream.runForEach(eventStream, () =>
+      Effect.sync(() => {
+        subTarget.dispatchEvent(new Event("foo"));
+      }));
+  } else {
+    yield* Stream.runDrain(eventStream);
+  }
+});
+
+await scenario(
+  "effect.events",
+  (depth) => call(() => Effect.runPromise(start(depth))),
+);

tasks/bench/scenarios/effect.recursion.ts

@@ -1,19 +1,19 @@
-import { Effect } from "npm:effect";
+import * as Effect from "https://raw.githubusercontent.com/Effect-TS/effect-smol/refs/heads/deno/src/Effect.ts";
 import { call } from "../../../mod.ts";
 import { scenario } from "./scenario.ts";
 
-await scenario("effect.recursion", (depth) =>
-  call(() => Effect.runPromise(recurse(depth)))
-);
+const recurse: (
+  depth: number,
+) => Effect.Effect<void> = Effect.fnUntraced(function* (depth) {
+  if (depth > 1) {
+    return yield* recurse(depth - 1);
+  }
+  for (let i = 0; i < 100; i++) {
+    yield* Effect.void;
+  }
+});
 
-function recurse(depth: number): Effect.Effect<void, never, never> {
-  return Effect.gen(function* () {
-    if (depth > 1) {
-      yield* recurse(depth - 1);
-    } else {
-      for (let i = 0; i < 100; i++) {
-        yield* Effect.promise(() => Promise.resolve());
-      }
-    }
-  });
-}
+await scenario(
+  "effect.recursion",
+  (depth) => call(() => Effect.runPromise(recurse(depth))),
+);

tasks/bench/scenarios/effect.startup.ts

@@ -1,20 +1,16 @@
-import { Effect, Fiber } from "npm:effect";
-import { call, ensure } from "../../../mod.ts";
+import * as Effect from "https://raw.githubusercontent.com/Effect-TS/effect-smol/refs/heads/deno/src/Effect.ts";
+import { action } from "../../../mod.ts";
 import { scenario } from "./scenario.ts";
 
 await scenario("effect.startup", function* (_, exit) {
   let start = performance.now();
 
-  const startup = Effect.gen(function* () {
+  const startup = Effect.suspend(() => {
     exit(performance.now() - start);
-    yield* Effect.promise(() => Promise.resolve());
+    return Effect.promise(() => Promise.resolve());
   });
 
   const fiber = Effect.runFork(startup);
 
-  yield* ensure(function* () {
-    yield* call(() => Effect.runPromise(Fiber.interrupt(fiber)));
-  });
-
-  return yield* call(() => Effect.runPromise(Fiber.join(fiber)));
+  return yield* action((resolve) => fiber.addObserver(() => resolve()));
 });

tasks/bench/scenarios/effection.startup.ts

@@ -1,4 +1,4 @@
-import { call, type Operation } from "../../../mod.ts";
+import { call, type Operation, spawn } from "../../../mod.ts";
 import { scenario } from "./scenario.ts";
 
 await scenario("effection.startup", function* (_, exit) {
@@ -9,5 +9,7 @@ await scenario("effection.startup", function* (_, exit) {
     yield* call(() => Promise.resolve());
   }
 
-  return yield* startup();
+  const task = yield* spawn(() => startup());
+
+  return yield* task;
 });