Function foldMapSafe

packages/printer/src/internal/docStream.ts:381–409

(
  self: DocStream.DocStream<A>,
  M: monoid.Monoid<M>,
  f: (a: A) => M
)

>(3, (self, M, f) => Effect.runSync(foldMapSafe(self, M, f)))

const foldMapSafe = <A, M>(
  self: DocStream.DocStream<A>,
  M: monoid.Monoid<M>,
  f: (a: A) => M
): Effect.Effect<M> => {
  switch (self._tag) {
    case "CharStream": {
      return Effect.suspend(() => foldMapSafe(self.stream, M, f))
    }
    case "TextStream": {
      return Effect.suspend(() => foldMapSafe(self.stream, M, f))
    }
    case "LineStream": {
      return Effect.suspend(() => foldMapSafe(self.stream, M, f))
    }
    case "PushAnnotationStream": {
      return Effect.map(
        Effect.suspend(() => foldMapSafe(self.stream, M, f)),
        (that) => M.combine(f(self.annotation), that)
      )
    }
    case "PopAnnotationStream": {
      return Effect.suspend(() => foldMapSafe(self.stream, M, f))
    }
    default: {
      return Effect.succeed(M.empty)
    }
  }
}

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