Comment vérifier si la Collecte n'est pas vide à l'aide de java Flux

Je suis nouveau sur Java 8. Je ne suis pas en mesure de comprendre ce qui est mauvais dans le morceau de code suivant. L'idée est d'envoyer Collection<User> si elle n'est pas vide. Mais si la collection est vide que les envoyés HttpStatus.NOT_FOUND Entité de réponse.

@RequestMapping(value = "/find/pks", 
                method = RequestMethod.GET, 
                produces = MediaType.APPLICATION_JSON_VALUE)
public ResponseEntity<Collection<User>> getUsers(@RequestBody final Collection<String> pks)
{
    return StreamSupport.stream(userRepository.findAll(pks).spliterator(), false)
         .map(list -> new ResponseEntity<>(list , HttpStatus.OK))
         .orElse(new ResponseEntity<>(HttpStatus.NOT_FOUND));
}

Eclipse me montre l'erreur dans le point suivant .orElse

La méthode orElse(new ResponseEntity<>(HttpStatus.NOT_FOUND)) est pas défini pour le type Stream<ResponseEntity<User>>

Mon interface de base de la méthode ressemble à ce qui suit

Iterable<T> findAll(Iterable<PK> pks);
Flux de données.map() renvoie un Flux de données, et d'un Flux n'a pas de orElse() la méthode. Vous créez votre propre vie compliquée en retournant un objet iterable. Pourquoi ne pas vous retourner une Liste ou d'un Ensemble, ou même d'une Collection, et d'utiliser la fonction isEmpty()? BTW, ce que vous êtes à la cartographie n'est pas une liste, c'est un utilisateur. Si vous voulez vraiment garder à l'aide de Itératif, l'utilisation itératif.iterator().hasNext() pour voir si elle est vide ou pas.
L'interface est fournie par l'un des ressorts. ))))
Ensuite, utilisez itératif.iterator().hasNext() pour voir si elle est vide ou pas. Mais cela dit, je ne voudrais pas retourner une erreur 404 dans un tel cas. il suffit de retourner un 200 avec une liste vide. 404 est une ressource inconnue vous essayez d'obtenir. Vous êtes à la recherche de ressources, et de ne pas trouver quoi que ce soit est un résultat valide.

OriginalL'auteur Saurabh Kumar | 2015-06-03

  1. 4

    Vous mélangez deux choses. La première tâche consiste à convertir le Iterable à un Collection qui vous pouvez en effet résoudre à l'aide de la Stream API:

    Collection<User> list=
    StreamSupport.stream(userRepository.findAll(pks).spliterator(), false)
   .collect(Collectors.toList());

    Noter que ce flux est un flux de Users, pas un flux de listes. Par conséquent, vous ne pouvez pas mapper un list à autre chose avec ce flux. Le map opération carte chaque élément de la diffuser à un nouvel élément.

    Alors vous pouvez utiliser cette liste pour créer la ResponseEntity

    return list.isEmpty()? new ResponseEntity<>(HttpStatus.NOT_FOUND):
                       new ResponseEntity<>(list, HttpStatus.OK);

    Vous pouvez combiner ces étapes, par la création d'un Collector effectuer ces étapes, même si cela ne fournissent aucun avantage, c'est seulement une question de style:

    ResponseEntity<User> responseEntity=
    StreamSupport.stream(userRepository.findAll(pks).spliterator(), false)
   .collect(Collectors.collectingAndThen(Collectors.toList(),
      list -> list.isEmpty()? new ResponseEntity<>(HttpStatus.NOT_FOUND):
                              new ResponseEntity<>(list, HttpStatus.OK) ));
    Merci beaucoup Holger pour votre réponse. J'ai modifié le code, et inclus la carte de la fonction de convertir chaque Utilisateur dans UserDTO. 'StreamSupport.flux(userRepository.findAll(pks).spliterator(), false).carte(UserDTO::nouvelle).recueillir des( Collectionneurs.collectingAndThen(Collectionneurs.toList(), list -> liste.isEmpty() ? nouveau ResponseEntity<>(HttpStatus.NOT_FOUND) : nouvelle ResponseEntity<>(liste, HttpStatus.OK)));'

    OriginalL'auteur Holger

  2. 5

    Il n'est pas nécessaire, et souvent une erreur, tasser le tout dans une seule ligne. Dans ce cas, vous ne pouvez pas - il n'y a pas d'API pour votre intention.

    Faire simple:

    Collection<User> list = <your stream code that gets a list>;
if (list.isEmpty())
    return new ResponseEntity<>(HttpStatus.NOT_FOUND);
return new ResponseEntity<>(list, HttpStatus.OK);

    mais si vous avez absolument doit:

    return <your code>.map(list -> new ResponseEntity<>(list, list.isEmpty() ? HttpStatus.NOT_FOUND : HttpStatus.OK));
    Il demande une version simplifiée d'un problème général. Si le filtrage a été appliqué à la collecte qui a produit le flux, il ne serait pas évident de savoir si elle est vide ou pas.

    OriginalL'auteur Bohemian

  3. 1

    Cela dépend de votre terminal fonctionnement du cours d'eau, rappelez-vous qu'un cours d'eau ne peuvent être consommés une fois.

    • Est-il un regroupement par/statistiques de l'opération? Ensuite, vous aurez un 0 nombre ou une carte vide de groupes.
    • Si elle recueille dans une liste c'est une liste vide.
    • Si c'est une des méthodes qui renvoie un Optional (comme findAny) alors vous pouvez utiliser l'option null vérification de méthodes.
    Mais n'est-ce pas le concept, il est à la recherche de flux et de transmission, mais n'côte-logique quand quelque chose passe à travers ? Afin de ne pas briser le concept de streaming ou de consommer une fois...

    OriginalL'auteur the8472