fs2 Stream 1.x / Simple example of retry with logging

StreamRetry.scala

import cats.effect.Sync
import io.chrisdavenport.log4cats.Logger
import cats._
import cats.implicits._
import scala.concurrent.duration._

class RetryExample[F[_]](implicit F: Sync[F], log: Logger[F]) {
  case class ApiError(msg: String) extends Exception(msg)
  
  private def getTempFromInternet: EitherT[F, ApiError, Float] = ???
  
  def getTempWithRetries: F[Float] = {
    val get: F[Float] = getTempFromInternet.value.map(_.leftWiden[Throwable]).rethrow
    val maxAttempts = 5
    fs2.Stream.retry(
      fo = get.onError(e => log.error(e)("Attempt failed")),
      delay = 500.millis,
      nextDelay = _ * 2,
      maxAttempts = maxAttempts,
    ).onError(e => log.error(e)(s"Failed to get temperature after $maxAttempts tries"))
     .compile.lastOrError
  }
}