Описание тега streamex

StreamEx - библиотека, улучшающая Java Streams. Используйте этот тег для вопросов о конкретном использовании этой библиотеки.
2 ответа

Потоковая группировка значений

Есть ли нетерминальная версия groupingBy или какой-то другой аккуратный способ для потоковой передачи в результате записи / значения карты? Я чувствую, что хочу просмотреть значения после groupingBy но лучшее, что я мог придумать, это не красиво: St…
09 фев '16 в 11:10
4 ответа

Группировка StreamEx по спискам возвращает неверное количество записей

Следующий код разбивает поток объектов на куски по 1000, обрабатывает их при материализации и возвращает общее количество объектов в конце. Во всех случаях возвращаемое число является правильным, если размер потока не равен 1. В случае, если размер …
12 авг '17 в 11:58
1 ответ

Как развернуть StreamEx в "Простой старый поток Java"?

StreamEx - мощная библиотека, но в какой-то момент мне больше не нужны ее суперспособности. Как я могу избавиться от внутренних накладных расходов StreamEx? Может ли это создать проблему? Ex. public void process(Path path){ StreamEx.of(Files.lines(p…
23 ноя '15 в 14:24
2 ответа

Удалите пустые дополнительные функции из потока, используя StreamEx

Я ищу элегантный способ для потоковой передачи только непустой Optional записи с использованием библиотеки StreamEx. Или стандартная библиотека, если это возможно. В настоящее время я использую следующий, довольно многословный подход: List<Option…
24 янв '18 в 09:47
2 ответа

StreamEx.parallel(). ForEach() не работает параллельно после.map()

Я заметил, что если я использую библиотеку StreamEx для распараллеливания моих потоков с пользовательским ForkJoinPool, как показано ниже - последующие действия выполняются в параллельных потоках из этого пула. Однако, если я добавлю операцию map ()…
21 окт '16 в 13:01
1 ответ

Создать карту с помощью SimpleEntry и StreamEx

Я видел пример StreamEx, который довольно хорош и который выглядит так Map<String, String> toMap = StreamEx.of(splittedTimeUnit1) .pairMap((s1, s2) -> s1.matches("-?\\d+(\\.\\d+)?") ? new String[]{s2, s1} : null) .nonNull() .toMap(a -> a…
14 дек '16 в 09:31
1 ответ

Добавить метод в поток Java 8

Работая с Java 8 Stream s, я иногда обнаруживаю, что Stream не имеет конкретного метода, который мне нужен ( например, takeWhile(), dropWhile (), skipLast()). Как мне создать свой собственный класс потока, который имеет дополнительные методы без пер…
25 янв '16 в 17:48
1 ответ

Как мне суммировать двойные значения потока карты в streamex?

Библиотека StreamEx, кажется, действительно помогает мне писать потоки Java 8 кратко, особенно при рассмотрении карт (используя mapKeyValueНапример, вместо того, чтобы распаковывать записи карты вручную). Если у меня есть поток записей на карте, в в…
22 фев '16 в 15:58
1 ответ

Должен ли параллелизм StreamEx работать при использовании takeWhile?

У меня есть поток, который я создаю так: StreamEx.generate(new MySupplier<List<Entity>>()) .flatMap(List::stream) .map(Entity::getName) .map(name -> ...) .. // more stuff Я могу изменить это, чтобы работать параллельно, просто добавив…
14 янв '17 в 14:33
1 ответ

Внешняя нулевая аннотация Eclipse для AbstractStreamEx.nonNull()

Рассмотрим следующий пример кода. Этот код использует Eclipse's @NonNull а также @Nullable аннотации для проверки nulls. К сожалению, Eclipse помечает ошибку на линии map(toNonNull), import java.util.function.Function; import org.eclipse.jdt.annotat…
23 ноя '16 в 21:23
5 ответов

Собирайте пары из потока

У меня есть поток таких объектов: "0", "1", "2", "3", "4", "5", Как я могу преобразовать его в поток пар: { new Pair("0", "1"), new Pair("2", "3"), new Pair("4", "5")}. Размер потока неизвестен. Я читаю данные из файла, который может быть большим. У…
28 фев '18 в 10:52
1 ответ

Java-поток и группировка: поместить объект в несколько групп

Не думаю, что это называется "группировка", но мне нужно добиться следующего: у меня есть класс class Person { String name; Set<String> groups; } У меня есть несколько человек: Отец => {"Рабочий", "Мужчины"} Мать => {"Женщина"} Сын => {"Студен…
29 янв '20 в 16:45
1 ответ

Объединить список pojos в карту целых чисел, которые можно объединить по ключу

Я пытаюсь реализовать следующую логику: У меня есть карта целочисленных идентификаторов с целым числом. У меня есть список Pojos, представляющих идентификаторы. Я хочу объединить эти два и получить карту pojos для целого числа. На данный момент у ме…
21 ноя '19 в 20:46
1 ответ

Почему StreamEx заставляет меня добавлять "? Extends" к типу переменной при сборе в список?

Я заметил, что в случае ниже стандартного потока Java лучше "вычислить" тип переменной, чем StreamEx. Это странно, потому что люди любят StreamEx и используют его повсюду, но затем код загрязняется знаком "?". Я хочу использовать List<Class<?&…
17 сен '20 в 23:50
1 ответ

Как распечатать streamex на консоли

я пытаюсь распечатать все элементы streamex на консоли, но всегда получаю эту проблему [электронная почта защищена] Итак, я вызываю метод «конвертировать» из основного, но он не работает. У вас есть идеи, как я могу сделать это правильно? Я надеюсь …
12 ноя '22 в 09:38