in tormenta-avro/src/main/scala/com/twitter/tormenta/scheme/avro/InjectionScheme.scala [30:37]
override def decode(buf: ByteBuffer): TraversableOnce[T] = {
val bytes = Array.ofDim[Byte](buf.remaining())
buf.get(bytes)
inj.invert(bytes) match {
case Success(x) => Seq(x)
case Failure(x) => throw x
}
}