mirror of
https://github.com/vercel-labs/scriptc.git
synced 2026-10-26 06:34:20 +08:00
4 lines
313 B
TypeScript
4 lines
313 B
TypeScript
import * as Effect from "effect/Effect"
|
|
import * as Stream from "effect/Stream"
|
|
Effect.runPromise((Stream.make(1,2,3).pipe(Stream.mapEffect(n=>Effect.succeed(n*2).pipe(Effect.delay("1 millis")),{concurrency:2}),Stream.runCollect)).pipe(Effect.tap(value => Effect.sync(() => console.log(JSON.stringify(value))))))
|