Function unpackString

packages/platform/src/Ndjson.ts:178–196

(options?: NdjsonOptions)

 * @category constructors
 */
export const unpackString = <IE = never, Done = unknown>(options?: NdjsonOptions): Channel.Channel<
  Chunk.Chunk<unknown>,
  Chunk.Chunk<string>,
  IE | NdjsonError,
  IE,
  Done,
  Done
> => {
  const lines = Channel.splitLines<IE, Done>().pipe(
    options?.ignoreEmptyLines === true ?
      Channel.pipeTo(filterEmptyChannel()) :
      identity
  )
  return Channel.mapOutEffect(lines, (chunk) =>
    Effect.try({
      try: () => Chunk.map(chunk, (_) => JSON.parse(_)),
      catch: (cause) => new NdjsonError({ reason: "Unpack", cause })
    }))
}

const decodeString = <IE, Done>() => {
  const decoder = new TextDecoder()