PipeUtils.scala

import fs2._

def pipeR[F, A, B, C](pipe: Pipe[F, B, C]): Pipe[F, (A, B), (A, C)] = {
  s =>
    s.map(_._1).zip(s.map(_._2).through(pipe))
}

def pipeL[F, A, B, C](pipe: Pipe[F, A, C]): Pipe[F, (A, B), (C, B) = {
  s =>
    s.map(_._1).through(pipe).zip(s.map(_._2))
}