Überprüfen Sie die Instanz im Stream

Ich habe folgenden Ausdruck:

scheduleIntervalContainers.stream()
        .filter(sic -> ((ScheduleIntervalContainer) sic).getStartTime() != ((ScheduleIntervalContainer)sic).getEndTime())
        .collect(Collectors.toList());

... wo scheduleIntervalContainershat Elementtyp ScheduleContainer:

final List<ScheduleContainer> scheduleIntervalContainers

Ist es möglich, den Typ vor dem Filter zu überprüfen?

Sie können eine andere anwenden filter, um nur die ScheduleIntervalContainerInstanzen beizubehalten. mapWenn Sie eine hinzufügen, werden die späteren Besetzungen gespeichert:

scheduleIntervalContainers.stream()
    .filter(sc -> sc instanceof ScheduleIntervalContainer)
    .map (sc -> (ScheduleIntervalContainer) sc)
    .filter(sic -> sic.getStartTime() != sic.getEndTime())
    .collect(Collectors.toList());

Wie Holger kommentierte, können Sie die Lambda-Ausdrücke durch Methodenreferenzen ersetzen, wenn Sie diesen Stil bevorzugen:

scheduleIntervalContainers.stream()
    .filter(ScheduleIntervalContainer.class::isInstance)
    .map (ScheduleIntervalContainer.class::cast)
    .filter(sic -> sic.getStartTime() != sic.getEndTime())
    .collect(Collectors.toList());

Eine ziemlich elegante Option ist die Verwendung der Methodenreferenz der Klasse:

scheduleIntervalContainers
  .stream()
  .filter( ScheduleIntervalContainer.class::isInstance )
  .map( ScheduleIntervalContainer.class::cast )
  .filter( sic -> sic.getStartTime() != sic.getEndTime())
  .collect(Collectors.toList() );

Es gibt ein kleines Problem mit der @ Eran- Lösung - die Eingabe des Klassennamens in beiden filterund mapist fehleranfällig - es ist leicht zu vergessen, den Namen der Klasse an beiden Stellen zu ändern. Eine verbesserte Lösung wäre ungefähr so:

private static <T, R> Function<T, Stream<R>> select(Class<R> clazz) {
    return e -> clazz.isInstance(e) ? Stream.of(clazz.cast(e)) : null;
}

scheduleIntervalContainers
  .stream()
  .flatMap(select(ScheduleIntervalContainer.class))
  .filter( sic -> sic.getStartTime() != sic.getEndTime())
  .collect(Collectors.toList());   

Es kann jedoch zu Leistungseinbußen kommen, wenn Streamfür jedes übereinstimmende Element ein erstellt wird. Seien Sie vorsichtig, wenn Sie es für große Datenmengen verwenden. Ich habe diese Lösung von @ Tagir Vailev gelernt