override def listObjects(bucketName: String, prefix: String, maxKeys: Long): IO[S3Exception, S3ObjectListing] =
    execute(
      _.listObjectsV2(
        ListObjectsV2Request.builder().maxKeys(maxKeys.intValue()).bucket(bucketName).prefix(prefix).build()
      )
    ).map(S3ObjectListing.fromResponse)

  def execute[T](f: S3AsyncClient => CompletableFuture[T]): ZIO[Any, S3Exception, T] =
    ZIO.fromCompletionStage(f(unsafeClient)).refineToOrDie[S3Exception]

  def fromCompletionStage[A](cs: => CompletionStage[A]): Task[A] = javaz.fromCompletionStage(cs)

RepositoryContext[F](repo1, repo2 ..)
SomeService[F](implicit val ctx: F HasContext RepositoryContext[F]) {
  def foo = F.ask(ctx => …)
}