We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 73ba963 commit d71e533Copy full SHA for d71e533
tormenta-core/src/main/scala/com/twitter/tormenta/scheme/Scheme.scala
@@ -30,7 +30,7 @@ import org.slf4j.LoggerFactory
30
*/
31
32
object Scheme {
33
- val identity: Scheme[ByteBuffer] = Scheme(Some(_))
+ val identity: Scheme[ByteBuffer] = Scheme(Iterator.single)
34
35
def apply[T](decodeFn: ByteBuffer => TraversableOnce[T]) =
36
new Scheme[T] {
0 commit comments