Scala & Slick: incompatibilité de type avec [Produit avec Serializable] doit être corrigé

Question

J'essaie d'implémenter une méthode qui récupère tous les utilisateurs en réutilisant une méthode qui récupère un seul utilisateur basé sur l'ID utilisateur, mais ne peut pas comprendre la discordance de type. Voulez-vous me dire comment résoudre ce problème?

UserDAOImpl.scala:

def findAll: Future[Seq[User]] = { 
    val dbUsers: Future[Seq[DbUser]] = db.run(users.result) 

    dbUsers.map { dbUserSeq => 
    dbUserSeq.map { dbUser => find(UUID.fromString(dbUser.userID)).value.get match { 
     case Success(Some(usr: User)) => usr 
     case _ => None 
    }} 
    } 
} 

Je laisse de côté la définition de find car il fonctionne très bien, mais voici la signature.

def find(userID: UUID): Future[Option[User]] = { 

Message d'erreur:

found : Seq[Product with Serializable] 
required: Seq[models.User] 
      dbUserSeq.map { dbUser => 
         ^

Juste au cas où, la définition des utilisateurs

private val users = TableQuery[UserTable] 

Toute suggestion serait appréciée.

Answer 1

Une approche non-blocage:

def findAll: Future[Seq[User]] = { 
    db.run(users.result) 
    .map(dbUserSeq => 
     Future.sequence(dbUserSeq.map(dbUser => find(UUID.fromString(dbUser.userID)))) 
    ) 
    .flatMap(userFutSeq => // userFutSeq is a Future[Seq[Option[User]]] 
     userFutSeq.map(userSeq => userSeq.collect { case Some(u) => u }) 
    ) 
} 

Le code ci-dessus regroupe les utilisateurs qui se trouvent et ne tient pas compte du reste.

Évitez d'utiliser Await sauf à des fins de test. Lorsque vous travaillez avec des contrats à terme, restez dans le contexte d'un Future.

Answer 2

Le code précédent avait en réalité plusieurs problèmes, et le code ci-dessous est la solution que j'ai trouvée jusqu'à présent. Peut-être pas le plus simple, mais ça a marché.

def findAll: Future[Seq[User]] = { 
    db.run(users.result).map { dbUserSeq => 
     dbUserSeq.map { dbUser => 
     val userFut: Future[Option[User]] = find(UUID.fromString(dbUser.userID)) 
     Await.ready(userFut, Duration.Inf).value.get match { 
      case Success(Some(usr: User)) => usr 
      case _ => throw new RuntimeException 
     } 
     } 
    } 
    }