gistfile1.txt

export function toLines(s1: Observable<{ toString() }>) {
  let lines$ = new Subject<string>()
  let acu = ''

  s1.subscribe({
    next: x => {
      acu += x.toString()
      if (!acu.includes('\n')) return
      let lines = acu.split('\n')
      let last = lines.pop()
      lines.forEach(x => lines$.next(x))
      acu = last
    },
    error: error => {
      throw error
    },
    complete: () => {
      if (acu.length > 0) {
        lines$.next(acu)
      }
    },
  })
  return lines$
}