import { Effect, Logger } from "effect"
const testEffect = (priority: number) =>
Effect.log(priority.toString())
.pipe(Effect.withSchedulingPriority(priority))
const sequence = Effect.all(
[
testEffect(1),
testEffect(2),
testEffect(0),
testEffect(1),
testEffect(2),
testEffect(0)
],
{ concurrency: "unbounded" }
).pipe(
Effect.provide(Logger.pretty),
Effect.runPromise
)
import { Effect, Logger } from "effect"
const testEffect = (priority: number) =>
Effect.log(priority.toString())
.pipe(Effect.withSchedulingPriority(priority))
const sequence = Effect.all(
[
testEffect(1),
testEffect(2),
testEffect(0),
testEffect(1),
testEffect(2),
testEffect(0)
],
{ concurrency: "unbounded" }
).pipe(
Effect.provide(Logger.pretty),
Effect.runPromise
)