Stream.interruptWhenDeferred doesn't instantly interrupt the stream about effect HOT 3 CLOSED

import { Deferred, Effect, Stream } from "effect"
import * as console from "node:console"

const s1 = Stream.make(1, 2, 3).pipe(
  Stream.tap(() => Effect.sleep("100 millis"))
)

const program = Effect.gen(function*() {
  const interrupt = yield* Deferred.make<void>()
  return yield* s1.pipe(
    Stream.tap(() => Deferred.succeed(interrupt, void 0)),
    Stream.interruptWhenDeferred(interrupt),
    Stream.runCollect
  )
})

Effect.runPromise(program).then(
  (r) => console.log(r),
  (e) => console.error(e)
)

import { Deferred, Effect, Stream } from "effect"
import * as console from "node:console"

const s1 = Stream.make(1, 2, 3).pipe(
  Stream.tap(() => Effect.yieldNow({ priority: 1 }))
)

const program = Effect.gen(function*() {
  const interrupt = yield* Deferred.make<void>()
  return yield* s1.pipe(
    Stream.tap(() => Deferred.succeed(interrupt, void 0)),
    Stream.interruptWhenDeferred(interrupt),
    Stream.runCollect
  )
})

Effect.runPromise(program).then(
  (r) => console.log(r),
  (e) => console.error(e)
)