import {filter} from './filter'
import {type JSONOptions, parseJSON} from './json'
import {split} from './split'

export function parse<Type>(
  it: AsyncIterableIterator<string>,
  options?: JSONOptions<Type>,
): AsyncIterableIterator<Type> {
  return parseJSON(
    filter(split(it, '\n'), (line) => Boolean(line && line.trim())),
    options,
  )
}

export async function* stringify(iterable: AsyncIterableIterator<unknown>) {
  for await (const doc of iterable) {
    yield `${JSON.stringify(doc)}\n`
  }
}