fn pub static new(input: I) -> Parser[I] {
  Parser(
    input: BufferedReader.new(input),
    buffer: ByteArray.new,
    offset: 0,
    separator: Separator.Comma.to_int,
  )
}

fn pub mut all?(func: fn (T) -> Bool) -> Bool {
  loop {
    match self.next {
      case Some(v) -> if func.call(v).false? { return false }
      case _ -> return true
    }
  }
}

fn pub mut any?(func: fn (T) -> Bool) -> Bool {
  loop {
    match self.next {
      case Some(v) -> if func.call(v) { return true }
      case _ -> return false
    }
  }
}

fn pub move chain[I: mut + Iter[T]](other: I) -> Stream[T] {
  let mut iter_left = true

  Stream.new(fn move {
    if iter_left {
      let item = self.next

      if item.some? { return item } else { iter_left = false }
    }

    other.next
  })
}

fn pub move chunks(size: Int) -> Stream[Array[T]] {
  Stream.new(fn move {
    let chunk = []

    while chunk.size < size {
      match self.next {
        case Some(val) -> chunk.push(val)
        case _ -> break
      }
    }

    if chunk.empty? { Option.None } else { Option.Some(chunk) }
  })
}

fn pub mut column -> Result[String, Error] {
  try read_column
  Result.Ok(@buffer.drain_to_string)
}

fn pub mut column? -> Result[Bool, Error] {
  match try peek {
    case Some(CR or LF) or None -> Result.Ok(false)
    case Some(_) -> Result.Ok(true)
  }
}

fn pub move count -> Int {
  reduce(0, fn (count, _) { count + 1 })
}

fn pub move each(func: fn (T)) {
  loop {
    match self.next {
      case Some(v) -> func.call(v)
      case _ -> return
    }
  }
}

fn pub move each_with_index(func: fn (Int, T)) {
  let mut idx = 0

  each(fn move (value) { func.call(idx := idx + 1, value) })
}

fn pub mut find(func: fn (ref T) -> Bool) -> Option[T] {
  loop {
    match self.next {
      case Some(v) -> if func.call(v) { return Option.Some(v) }
      case _ -> return Option.None
    }
  }
}

fn pub mut find_map[R](func: fn (T) -> Option[R]) -> Option[R] {
  loop {
    match self.next {
      case Some(v) -> {
        match func.call(v) {
          case Some(r) -> return Option.Some(r)
          case _ -> {}
        }
      }
      case _ -> return Option.None
    }
  }
}

fn pub mut headers -> Result[Map[String, Int], Error] {
  let map = Map.new
  let mut i = 0

  while try column? { map.set(try column, i := i + 1) }

  try next_line
  Result.Ok(map)
}

fn pub move last -> Option[T] {
  reduce(Option.None, fn (_, val) { Option.Some(val) })
}

fn pub move map[R](func: fn (T) -> R) -> Stream[R] {
  Stream.new(fn move { self.next.map(fn (v) { func.call(v) }) })
}

fn pub mut next -> Option[Result[Array[String], Error]] {
  let mut cols = []

  loop {
    loop {
      match column? {
        case Ok(true) -> {
          match column {
            case Ok(v) -> cols.push(v)
            case Error(e) -> return Option.Some(Result.Error(e))
          }
        }
        case Ok(false) -> break
        case Error(e) -> return Option.Some(Result.Error(e))
      }
    }

    match next_line {
      case Ok(false) if cols.empty? -> return Option.None
      case Ok(true) if cols.empty? -> {}
      case Ok(_) -> return Option.Some(Result.Ok(cols))
      case Error(e) -> return Option.Some(Result.Error(e))
    }
  }
}

fn pub mut next_line -> Result[Bool, Error] {
  match try peek {
    case Some(CR) -> {
      try read_byte
      try require_newline
    }
    case Some(LF) -> try read_byte
    case Some(_) -> throw error(ErrorKind.UnexpectedCharacter)
    case None -> return Result.Ok(false)
  }

  match try peek {
    case Some(_) -> Result.Ok(true)
    case None -> {
      try read_byte
      Result.Ok(false)
    }
  }
}

fn pub offset -> Int {
  @offset
}

fn pub move partition(func: fn (ref T) -> Bool) -> (Array[T], Array[T]) {
  reduce(([], []), fn move (acc, val) {
    if func.call(ref val) { acc.0.push(val) } else { acc.1.push(val) }

    acc
  })
}

fn pub move peekable -> Peekable[T] {
  Peekable(iter: self, peeked: Option.None)
}

fn pub move reduce[A](accumulator: A, func: fn (A, T) -> A) -> A {
  let mut result = accumulator

  loop {
    match self.next {
      case Some(v) -> result = func.call(result, v)
      case _ -> return result
    }
  }
}

fn pub move select(func: fn (ref T) -> Bool) -> Stream[T] {
  Stream.new(fn move {
    loop {
      match self.next {
        case Some(v) -> if func.call(v) { return Option.Some(v) }
        case _ -> return Option.None
      }
    }
  })
}

fn pub move select_map[R](func: fn (T) -> Option[R]) -> Stream[R] {
  Stream.new(fn move {
    loop {
      match self.next {
        case Some(v) -> {
          match func.call(v) {
            case Some(r) -> return Option.Some(r)
            case _ -> next
          }
        }
        case _ -> return Option.None
      }
    }
  })
}

fn pub mut separator=(separator: ref Separator) {
  @separator = separator.to_int
}

fn pub move skip(amount: Int) -> Stream[T] {
  let mut pending = amount

  Stream.new(fn move {
    while pending > 0 {
      match self.next {
        case Some(_) -> pending -= 1
        case _ -> break
      }
    }

    self.next
  })
}

fn pub mut skip_column -> Result[Nil, Error] {
  try read_column
  @buffer.clear
  Result.Ok(nil)
}

fn pub mut skip_columns(amount: Int) -> Result[Nil, Error] {
  let mut i = 0

  while (i := i + 1) < amount { try skip_column }

  Result.Ok(nil)
}

fn pub mut skip_line -> Result[Nil, Error] {
  loop {
    match try read_byte {
      case Some(LF) -> break
      case Some(_) -> {}
      case None -> break
    }
  }

  Result.Ok(nil)
}

fn pub move skip_while(func: fn (ref T) -> Bool) -> Stream[T] {
  let mut skip = true

  Stream.new(fn move {
    while skip {
      match self.next {
        case Some(v) if func.call(v) -> {}
        case Some(v) -> {
          skip = false
          return Option.Some(v)
        }
        case _ -> return Option.None
      }
    }

    self.next
  })
}

fn pub move take(amount: Int) -> Stream[T] {
  let mut pending = amount

  Stream.new(fn move {
    if (pending := pending - 1) > 0 { self.next } else { Option.None }
  })
}

fn pub move take_while(func: fn (ref T) -> Bool) -> Stream[T] {
  let mut take = true

  Stream.new(fn move {
    if take {
      match self.next {
        case Some(v) if func.call(v) -> Option.Some(v)
        case Some(_) -> {
          take = false
          Option.None
        }
        case _ -> Option.None
      }
    } else {
      Option.None
    }
  })
}

fn pub move to_array -> Array[T] {
  reduce([], fn (values, value) {
    values.push(value)
    values
  })
}

fn pub mut try_each[E](func: fn (T) -> Result[Nil, E]) -> Result[Nil, E] {
  loop {
    match self.next {
      case Some(v) -> try func.call(v)
      case _ -> return Result.Ok(nil)
    }
  }
}

fn pub mut try_reduce[A, E](
  accumulator: A,
  func: fn (A, T) -> Result[A, E],
) -> Result[A, E] {
  let mut result = accumulator

  loop {
    match self.next {
      case Some(v) -> result = try func.call(result, v)
      case _ -> return Result.Ok(result)
    }
  }
}

fn pub move with_index -> Stream[(Int, T)] {
  let mut index = 0

  map(fn move (val) { (index := index + 1, val) })
}

fn pub move zip[U, I: mut + Iter[U]](other: I) -> Stream[(T, U)] {
  Stream.new(fn move { self.next.zip(other.next) })
}