Function stream

packages/platform-bun/src/internal/multipart.ts:12–27

(source: Request)

/** @internal */
export const stream = (source: Request): Stream.Stream<Multipart.Part, Multipart.MultipartError> =>
  pipe(
    Multipart.makeConfig({}),
    Effect.map((config) => {
      const parser = MP.make({
        ...config,
        headers: source.headers
      })
      return Stream.fromReadableStream(
        () => source.body!.pipeThrough(parser),
        (cause) => convertError(cause as MultipartError)
      )
    }),
    Stream.unwrap,
    Stream.map(convertPart)
  )

/** @internal */
export const persisted = (source: Request) =>