Streaming binary decoding example

streamingdecoding.scala

trait StreamDecoder[+A] {
  import scodec.stream.{decode => D}
  def mapEither[B](f: A => String \/ B): StreamDecoder[B] =
    flatMap { a => f(a).fold(D.fail, D.emit) }
}

val packets: StreamDecoder[MpegPacket] = pcapRecordStreamDecoder mapEither { record => 
  val datagramPayloadBits = record.data.drop(22 * 8).drop(20 * 8)
  decode.many[MpegPacket].decode(datagramPayloadBits)
}