StreamT marshaller

streamTMarshaller.scala

implicit def streamTMarshaller[M[+_]](implicit mtm: MarshallerM[M], M: Monad[M], arf: ActorRefFactory) = {
  new MarshallerM[({ type λ[α] = StreamT[M, α] })#λ] {
    override def marshaller[T](implicit mt: Marshaller[T]): Marshaller[StreamT[M, T]] = {
      new Marshaller[StreamT[M, T]] {
        override def apply(value: StreamT[M, T], ctx: MarshallingContext): Unit = {
          implicitly[MarshallerM[M]].marshaller[Stream[T]].apply(value.toStream, ctx)
        }
      }
    }
  }
}