Function stream

packages/platform-node-shared/src/internal/multipart.ts:16–32

(
  source: Readable,
  headers: IncomingHttpHeaders
)

/** @internal */
export const stream = (
  source: Readable,
  headers: IncomingHttpHeaders
): Stream.Stream<Multipart.Part, Multipart.MultipartError> =>
  pipe(
    Multipart.makeConfig(headers as any),
    Effect.map(
      (config) =>
        NodeStream.fromReadable<Multipart.MultipartError, MP.Part>(() => {
          const parser = MP.make(config)
          source.pipe(parser)
          return parser
        }, (error) => convertError(error as any))
    ),
    Stream.unwrap,
    Stream.map(convertPart)
  )

/** @internal */
export const persisted = (