Stream.runDrain and Fork Interruption Issue in Effect Typescript

import { Effect, SubscriptionRef, Stream, Fiber } from "effect"
import { NodeRuntime } from "@effect/platform-node"

const testInterruption = Effect.acquireRelease(
  Effect.gen(function* () {
    yield* Effect.log("[Test] Starting test...")

    // Create a SubscriptionRef with a Set
    const dataRef = yield* SubscriptionRef.make(new Set<string>())

    // Fork a fiber that listens to changes and logs them
    const listenerFiber = yield* Effect.fork(
      dataRef.changes.pipe(
        Stream.mapEffect(() =>
          Effect.void
        ),
        Stream.runDrain
      )
    )

    yield* Effect.log("[Test] Listener fiber started")

    return { listenerFiber }
  }),
  ({ listenerFiber }) =>
    Effect.gen(function* () {
      yield* Effect.log("[Test] Starting cleanup - interrupting listener fiber...")
      yield* Fiber.interrupt(listenerFiber)
      yield* Effect.log("[Test] Listener fiber interrupted successfully")
    })
).pipe(
  Effect.map(() => void 0)
)

const program = Effect.gen(function* () {
  yield* Effect.log("[Main] Starting program")

  yield* testInterruption
  yield* Effect.log("[Main] Program complete")
})

NodeRuntime.runMain(program.pipe(Effect.scoped))

Here are the logs:
[12:07:19.124] INFO (#1): [Main] Starting program
[12:07:19.124] INFO (#1): [Test] Starting test...
[12:07:19.125] INFO (#1): [Test] Listener fiber started
[12:07:19.125] INFO (#1): [Main] Program complete
[12:07:19.125] INFO (#1): [Test] Starting cleanup - interrupting listener fiber...