Using Effect Queue for Job Processing in a Remix App

// MyQueue.ts
import { Effect, Queue } from "effect";

const q = Queue.unbounded();

export const send = (a) =>
  Effect.gen(function* () {
    const q_ = yield* q;
    yield* Queue.offer(q_, a);
  });

const supervisor = Effect.gen(function* () {
  const q_ = yield* q;
  while (true) {
    const elem = yield* Queue.take(q_);
    console.log(elem);
  }
});

Effect.runPromise(supervisor);

// Server.ts
import express from "express";
import bodyParser from "body-parser";
import { Effect } from "effect";

const app = express();
app.use(bodyParser.json());
const port = 3000;

import { send } from "./MyQueue.js";

app.post("/", (req, res) => {
  Effect.runPromise(send(req.body));
  res.send("recieved POST");
});

app.listen(port, () => {
  console.log(`Example app listening on port ${port}`);
});