def decode()

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
  }