Function scheduleDefectRefail

packages/effect/src/internal/stream.ts:5595–5596

(self: Stream.Stream<A, E, R>)

  }))

const scheduleDefectRefail = <A, E, R>(self: Stream.Stream<A, E, R>) =>
  catchAllCause(self, (cause) => failCause(InternalSchedule.scheduleDefectRefailCause(cause)))

/** @internal */
export const run = dual<