Yess finally got it, the trick was to use toPipe!

Notes:
* probably should change `object ThriftLoader extendsCollectorLoader[Array[Byte]]`
  to `object ThriftLoader extends CollectorLoader[SnowplowRawEvent]`
* PIPES