This is what we can use to fix EndOfStream errors for ember

EmberRetryFix.scala

object EmberRetryFix {
  import cats.syntax.all._
  import scala.concurrent.duration._
  import org.http4s._
  import org.http4s.client._
  import org.http4s.ember.core.EmberException
  import org.http4s.client.middleware._
  import org.http4s.headers.`Idempotency-Key`


  def fixIt[F[_]: Temporal](emberClient: Client[F]): Client[F] = Retry(retryUntilFresh)(emberClient)

  private val retryNow = 0.seconds.some
  def retryUntilFresh[F[_]]: RetryPolicy[F] = {(req, result, retries) =>
    if (emberDeadFromPoolPolicy(req, result)) retryNow
    else None
  }

  def emberDeadFromPoolPolicy[F[_]](req: Request[F], result: Either[Throwable, Response[F]]): Boolean =
    (req.method.isIdempotent || req.headers.get[`Idempotency-Key`].isDefined) &&
      isEmptyStreamError(result)

  def isEmptyStreamError[F[_]](result: Either[Throwable, Response[F]]): Boolean =
    result match {
      case Right(resp) => false
      // case Left(EmberException.EmptyStream()) => true // Next version
      case Left(org.http4s.ember.core.Parser.MessageP.EndOfStreamError()) => true
      case _ => false
    }
}