Periodically show the amount of elements produced by an fs2 stream

showProcessedCount.scala

def showProcessedCount[F[_]: Concurrent: Timer, A]: Pipe[F, A, A] = stream =>
  fs2.Stream.eval(Ref[F].of(0)).flatMap { count =>
    stream.chunks
      .evalMap { chunk =>
        count.update(_ + chunk.size).as(chunk)
      }
      .flatMap(fs2.Stream.chunk)
      .concurrently(
        fs2.Stream
          .awakeEvery[F](1.second)
          .zip(fs2.Stream.repeatEval(count.get))
          .map { case (dur, count) =>
            s"Processed $count elements in ${dur.toSeconds} seconds"
          }
          .showLinesStdOut
      )
  }