Self contained ByteString scodec decoder mechanism

DecoderGather.scala

import akka.util.ByteString
import scodec.Attempt.Successful
import scodec.DecodeResult
import scodec.Decoder
import scodec.bits.BitVector

class DecoderGather[R](decoder: Decoder[R]) {
  private var bitBuffer = BitVector.empty

  def apply(chunk: ByteString): Seq[R] = {
    chunk.asByteBuffers.map(BitVector.apply).foreach(bb => bitBuffer = bitBuffer ++ bb)
    doParsing(Vector.empty)
  }

  @tailrec
  private def doParsing(parsedSoFar: Vector[R]): Vector[R] =
    decoder.decode(bitBuffer) match {
      case Successful(DecodeResult(value, remainder)) =>
        bitBuffer = remainder
        doParsing(parsedSoFar :+ value)
      case _ => parsedSoFar
    }
}