use scheduler instead of queueMicrotask

packages/effect/src/internal/stream.ts

@@ -10,6 +10,7 @@ import * as Either from "../Either.js"
 import * as Equal from "../Equal.js"
 import * as Exit from "../Exit.js"
 import * as Fiber from "../Fiber.js"
+import * as FiberRef from "../FiberRef.js"
 import type { LazyArg } from "../Function.js"
 import { constTrue, dual, identity, pipe } from "../Function.js"
 import * as Layer from "../Layer.js"
@@ -628,7 +629,9 @@ export const asyncPush = <A, E = never, R = never>(
     queueFromBufferOptionsPush<A, E>(options),
     Queue.shutdown
   ).pipe(
-    Effect.tap((queue) => register(emit.makePush(queue))),
+    Effect.tap((queue) =>
+      FiberRef.getWith(FiberRef.currentScheduler, (scheduler) => register(emit.makePush(queue, scheduler)))
+    ),
     Effect.map((queue) => {
       const loop: Channel.Channel<Chunk.Chunk<A>, unknown, E> = core.flatMap(Queue.take(queue), (item) =>
         Exit.isExit(item)

packages/effect/src/internal/stream/emit.ts

@@ -5,6 +5,7 @@ import * as Exit from "../../Exit.js"
 import { pipe } from "../../Function.js"
 import * as Option from "../../Option.js"
 import type * as Queue from "../../Queue.js"
+import type * as Scheduler from "../../Scheduler.js"
 import type * as Emit from "../../StreamEmit.js"
 
 /** @internal */
@@ -47,7 +48,10 @@ export const make = <R, E, A, B>(
 }
 
 /** @internal */
-export const makePush = <E, A>(queue: Queue.Queue<Array<A> | Exit.Exit<void, E>>): Emit.EmitOpsPush<E, A> => {
+export const makePush = <E, A>(
+  queue: Queue.Queue<Array<A> | Exit.Exit<void, E>>,
+  scheduler: Scheduler.Scheduler
+): Emit.EmitOpsPush<E, A> => {
   let finished = false
   let buffer: Array<A> = []
   let running = false
@@ -62,7 +66,7 @@ export const makePush = <E, A>(queue: Queue.Queue<Array<A> | Exit.Exit<void, E>>
     }
     if (!running) {
       running = true
-      queueMicrotask(flush)
+      scheduler.scheduleTask(flush, 0)
     }
     return true
   }
@@ -88,7 +92,7 @@ export const makePush = <E, A>(queue: Queue.Queue<Array<A> | Exit.Exit<void, E>>
       buffer.push(value)
       if (!running) {
         running = true
-        queueMicrotask(flush)
+        scheduler.scheduleTask(flush, 0)
       }
       return true
     },