Function flush

packages/effect/src/internal/stream/emit.ts:73–79

()

    return true
  }
  function flush() {
    running = false
    if (buffer.length > 0) {
      queue.unsafeOffer(buffer)
      buffer = []
    }
  }
  function done(exit: Exit.Exit<A, E>) {
    if (finished) return
    finished = true