Вопросы с тегом «stream»

87
Java 8, Streams для поиска повторяющихся элементов

Я пытаюсь перечислить повторяющиеся элементы в целочисленном списке, например, List<Integer> numbers = Arrays.asList(new Integer[]{1,2,1,3,4,4}); using Streams of jdk 8. Кто-нибудь пробовал. Чтобы удалить дубликаты, мы можем использовать отдельный () api. Но как насчет поиска повторяющихся...

87
Ошибка аутентификации, поскольку удаленная сторона закрыла транспортный поток

Я разрабатываю TCP-клиент для подключения сервера OpenSSL с проверкой подлинности сертификата. Я использую файлы .crt и .key, общие для серверной команды. Эти сертификаты генерируются командами OpenSSL. Я использую SslStreamобъект для аутентификации клиента Tcp, вызывая...

86
Самый эффективный способ создания InputStream из OutputStream

На этой странице: http://blog.ostermiller.org/convert-java-outputstream-inputstream описывается, как создать InputStream из OutputStream: new ByteArrayInputStream(out.toByteArray()) Другие альтернативы - использование PipedStreams и новых потоков, что является громоздким. Мне не нравится идея...

86
сброс строкового потока

Как мне «сбросить» состояние строкового потока до того, каким оно было при его создании? int firstValue = 1; int secondValue = 2; std::wstringstream ss; ss << "Hello: " << firstValue; std::wstring firstText(ss.str()); //print the value of firstText here //How do I "reset" the...

86
Как читать построчно или сразу весь текстовый файл?

Я нахожусь в учебнике, который знакомит с файлами (как читать и писать из \ в файл) Прежде всего, это не домашнее задание, это просто общая помощь, которую я ищу. Я знаю, как читать по одному слову за раз, но я не знаю, как читать по одной строке за раз или как читать весь текстовый файл. Что...

86
forEach против forEachOrdered в Java 8 Stream

Я понимаю, что эти методы различаются порядком выполнения, но во всех моих тестах я не могу добиться другого выполнения заказа. Пример: System.out.println("forEach Demo"); Stream.of("AAA","BBB","CCC").forEach(s->System.out.println("Output:"+s)); System.out.println("forEachOrdered Demo");...

86
Почему параллельный поток с лямбдой в статическом инициализаторе вызывает тупик?

Я столкнулся со странной ситуацией, когда использование параллельного потока с лямбдой в статическом инициализаторе, казалось бы, занимает вечность без использования ЦП. Вот код: class Deadlock { static { IntStream.range(0, 10000).parallel().map(i -> i).count(); System.out.println("done"); }...

85
GZIPInputStream построчное чтение

У меня есть файл в формате .gz. Класс Java для чтения этого файла - GZIPInputStream. Однако этот класс не расширяет класс BufferedReader для java. В результате я не могу читать файл построчно. Мне нужно что-то вроде этого reader = new MyGZInputStream( some constructor of GZInputStream)...

85
Получение std :: ifstream для обработки LF, CR и CRLF?

Конкретно меня интересует istream& getline ( istream& is, string& str );. Есть ли у конструктора ifstream возможность указать ему преобразовывать все кодировки новой строки в '\ n' под капотом? Я хочу иметь возможность вызывать getlineи изящно обрабатывать все окончания строк....

85
Как работает std :: flush?

Может кто-нибудь объяснить (желательно на простом английском), как std::flushработает? Что это такое? Когда бы вы промыли ручей? Почему это важно? Спасибо.

85
Пример метода Java 8 Streams FlatMap

Я проверял предстоящее Java update, а именно: Java 8 or JDK 8. Да, я нетерпелив, есть много нового, но есть кое-что, чего я не понимаю, простой код: final Stream<Integer>stream = Stream.of(1,2,3,4,5,6,7,8,9,10); stream.flatMap(); javadocs public <R> Stream<R>...

85
Большая разница (x9) во времени выполнения между почти идентичным кодом на C и C ++

Я пытался решить это упражнение с сайта www.spoj.com: FCTRL - Factorial Вам не обязательно это читать, просто сделайте это, если вам интересно :) Сначала я реализовал это на C ++ (вот мое решение): #include <iostream> using namespace std; int main() { unsigned int num_of_inputs; unsigned int...

84
Java 8: предпочтительный способ подсчета итераций лямбды?

Я часто сталкиваюсь с одной и той же проблемой. Мне нужно подсчитать прогоны лямбды для использования вне лямбды . Например: myStream.stream().filter(...).forEach(item -> { ... ; runCount++}); System.out.println("The lambda ran " + runCount + "times"); Проблема в том, что runCount должен быть...

84
Как сохранить порядок итерации списка при использовании Collections.toMap () в потоке?

Я создаю Mapиз a Listследующим образом: List<String> strings = Arrays.asList("a", "bb", "ccc"); Map<String, Integer> map = strings.stream() .collect(Collectors.toMap(Function.identity(), String::length)); Я хочу сохранить тот же порядок итераций, что и в List. Как я могу создать с...

84
Почему Stream.allMatch () возвращает true для пустого потока?

У нас с коллегой возникла ошибка, связанная с нашим предположением, что вызов пустого потока allMatch()вернется false. if (myItems.allMatch(i -> i.isValid()) { //do something } Конечно, это отчасти наша вина, если мы предполагаем, а не читаем документацию. Но я не понимаю, почему...