Function makeExportStream

packages/vue/examples/streamMutation.ts:45–52

(total: S.NonNegativeInt)

 * Each step is separated by a 50 ms delay to simulate real async work.
 */
const makeExportStream = (total: S.NonNegativeInt): Stream.Stream<ExportEvent> =>
  Stream.concat(
    Stream.range(1, total).pipe(
      Stream.map((completed) => new OperationProgress({ completed: S.NonNegativeInt(completed), total })),
      Stream.tap(() => Effect.sleep("50 millis"))
    ),
    Stream.make(new ExportComplete({ fileUrl: S.NonEmptyString("https://example.com/export.csv") }))
  )

// ---------------------------------------------------------------------------
// Option A: low-level `asStreamResult` (call inside a `setup()` function)