in tormenta-core/src/main/scala/com/twitter/tormenta/scheme/Scheme.scala [46:54]
def decode(buf: ByteBuffer): TraversableOnce[T]
def handle(t: Throwable): TraversableOnce[T] = {
// We assume this is rare enough that the perf hit of
// getLogger+getClass is better than
// forcing a new variable on everyone, even those that override this
LoggerFactory.getLogger(getClass).error("decoding error, ignoring", t)
List.empty
}