Вопросы с меткой [потоки-данных]

Вопросы о потоках данных (streams) — абстракции, используемой для чтения или записи файлов, сокетов и т. п. в единой манере. Для вопросов о потоках выполнения (threads) используйте метку [многопоточность]. Для вопросов о Java 8 Stream API используйте метку [java-stream].

Фильтрация
Сортировка
Метки
1 голос
1 ответ
63 показа

Парсинг и транформация данных в формате csv потоками (streams)

Собственно ниже предоставлю мой рабочий код. У меня есть претензии к его оптимизации. Как мне распарсить данные .csv и передать его в поток записи без дополнительных перемены? Размер данных превышает ...
PashaFromBY's user avatar
1 голос
2 ответа
60 показов

C++. Нужно ли перегружать operator<< над basic_ostream вместо ostream?

Даю возможность своему классу писать в ostream через оператор <<. friend static std::ostream& operator<<(std::ostream& stream, const my_type& arg) Но в принципе в будущем ведь ...
Halturin Evgeniy's user avatar
0 голосов
0 ответов
36 показов

Декодирование потока видео на node

Есть такая проблема в браузере нет звука для формата mkv как можно конвентировать на лету поток стрима? router.get('/:magnet/:fileName', (req: Request, res: Response, next: NextFunction) => { ...
EvilDev's user avatar
0 голосов
1 ответ
47 показов

FFmpeg avcodec_send_packet выдает ошибку -1094995529

Пытаюсь из sdp файла получить видео. Но так как впервые работаю с FFmpeg не могу понять, что я делаю не правильно. Данный sdp файл открывается в VLC без каких либо проблем. Команда ffplay -...
Михаил's user avatar
1 голос
0 ответов
82 показа

будет ли работать мьютекс на std::atomic_flag так как задумано?

Подскажите вот пример кода мьютекса идею которого я подсмотрел в одном из видео лекций МФТИ. Хотелось бы услышать ваше мнение о такой реализации и практическом использовании такого класса? class ...
Вячеслав's user avatar
2 голоса
1 ответ
142 показа

Пример асинхронной передачи данных через потоки данных

Можете показать пример, как написать 2 асинхронные задачи, чтобы они использовали один и тот же Stream (одна пишет, другая читает)? Ну и еще я хочу иметь возможность закинуть их в одну коллекцию и ...
Scrzii's user avatar
  • 186
0 голосов
0 ответов
41 показ

Как обойти явное ожидание selenium, чтобы пропустить итерацию цикла

Как сделать так, чтобы вовремя того как мы ждем с помощью wait.until() я мог выполнить параллельно другой код, который мог бы пропустить итерацию цикла, в котором находится код wait.until(). Например: ...
rom4ik44's user avatar
0 голосов
0 ответов
14 показов

stream_socket_server: Присвоить несколько IP-адресов

Как забиндить на сокет более одного IP-адреса, а именно для stream_socket_server и возможно ли такое? Вариант 0.0.0.0 не подойдёт. Нужно присвоить несколько IP-адресов, но не все
Semyon Bayandin's user avatar
0 голосов
0 ответов
49 показов

Изображение с формы повреждается ASP.NET 6 C# IFormFile

Через input typ=file выбираю изображение (несколько изображений). В крентроллер передаю его (их) с помощью IFormFileCollection. Пытаюсь сохранить его. Файл сохраняется нечитаемым (возможно, формат не ...
Vladimir's user avatar
0 голосов
0 ответов
25 показов

Как сделать поддержку стримов на Python для PyQt5

Делаю свой браузер на PyQt5. Задаюсь вопросом: как сделать так, чтобы можно было смотреть видеопотоки\стримы на сайтах? Имеется код с QMediaPlayer, но вылезает ошибка DirectShowPlayerService::doRender:...
tokimod's user avatar
  • 43
0 голосов
1 ответ
52 показа

Проблема с пониманием работы cin

Я новичок в программировании, изучаю его по книге Страуструпа. В главе 6 описан код и часть этого кода вызывает затруднение в понимании, а именно следующий блок: Token Token_stream::get() { if (...
kondiv's user avatar
  • 13
0 голосов
0 ответов
35 показов

Как воспроизвести видео через стрим и буферить?

У меня есть такой код, я тут выкачиваю mp4 и воспроизвожу через blob протокол. Сейчас все хорошо работает, но работает хорошо из-за того, что видео 20 секунд идет, но если взять 25 минутное видео в ...
Андрей's user avatar
0 голосов
1 ответ
180 показов

Воспроизвести аудиопоток .mp3 из интернета в Python

Мне нужно воспроизводить поток с этой ссылки: http://europaplus.hostingradio.ru:8014/ep-top256.mp3 Как это сделать в Python 3?
George-7777's user avatar
0 голосов
0 ответов
9 показов

Есть ли возможность использовать Filtered Stream Twitter бесплатно или с минимальными затратами?

писал свое приложение для пересылки твитов с твитера в телеграм, использовал для этого Filtered Stream, однако в один момент этот метод убрался с бесплатных тарифов и теперь только в Pro (5к$ в месяц) ...
Влад Гаврилюк's user avatar
0 голосов
0 ответов
36 показов

Найти корректно число старта xref таблицы в pdf документе

Допустим у меня есть большой pdf файл версии 1.6. И в конце файла должна быть информация: startxref 5638681 %%EOF Благодаря которой, естественно, система знает положение начала xref таблицы пдфа. Но ...
Mastas's user avatar
  • 26
0 голосов
1 ответ
222 показа

Как узнать размер файла С++?

В интернете есть несколько вариантов: просто перечитать весь файл (если файл большой, то не подходит из-за скорости), использовать tellg() (не подходит, так как ограничен на аппаратном уровне (не ...
Yulia's user avatar
  • 101
0 голосов
1 ответ
70 показов

Создание hashmap Java

Имеется текст, находящийся в файле. Требуется создать HashMap, где ключ равен первой букве слов в тексте, а значение - список всех слов, начинающихся с этой буквы. Если буква содержит менее 10 слов, ...
Olga's user avatar
  • 13
0 голосов
0 ответов
38 показов

Аудиопоток в режиме реального времени (аналог радио) на Node.JS

Возможно ли вообще на Node.JS сделать радио в режиме реального времени? Т.е. свой плейлист песен. Всё это дело объединяется в один аудиопоток и идет пользователям в режиме реального времени. Можно ли ...
rlways443's user avatar
-1 голос
1 ответ
53 показа

Несоответствие ожидаемому результату работы IntStream

Разбираюсь в многопоточности, дошёл до класса Phaser. Встретил пример. Phaser phaser = new Phaser(); IntStream.range(0, 3).forEach(i -> { phaser.register(); new Thread(() -> { ...
Lenny's user avatar
  • 45
0 голосов
0 ответов
18 показов

Постепенная подгрузка аудио при прослушивании

У меня есть проект с музыкой. (Nuxt.js + PHP на беке) Сейчас у меня прослушивание трека идет только после полной загрузки файла mp3 при нажатии на красную кнопку. На бекенде просто отдаю целиковый ...
mrzlanx532's user avatar
0 голосов
0 ответов
35 показов

Отключение цикла While True в определенном потоке определенного объекта модели django

Я уже сломал голову и изнасиловал ChatGPT. Подскажите пожалуйста, как правильно в этом коде остановить subprocess (часть неважных переменных я опустил): class Stream(models.Model): url = models....
Artem Filippov's user avatar
0 голосов
1 ответ
41 показ

Дан файл целых чисел. Получить новый файл, в котором располагаются сначала все совершенные элементы, а потом остальные [закрыт]

bool sov(int x) { int s = 0; for (int i = 1; i < x; i++) { if (x % i == 0) s += i; } if (s == x) return true; else return false; ...
Ирина Тхагапсо's user avatar
0 голосов
1 ответ
108 показов

Непонятная работа time.sleep()

Этот код проверяет, какое сейчас время и если время совпадает с указанным значением, то код отправляет уведомление. Почему-то код отправляет уведомления на час позже, хотя в else нету time.sleep() ...
NovAndr's user avatar
  • 17
1 голос
2 ответа
61 показ

Как работают InputStream в сокетах в java?

Задался вопросом, предположим на сервер (java servlet)передают огромный файл 100gb, я могу считать 1000 байт, остановиться, но в сетевом соединении передача данных будет же продолжаться, и если эти ...
Venot's user avatar
  • 595
1 голос
2 ответа
117 показов

C# Декорирование класса Stream

Задача заключается в следующем: необходимо задекорировать класс Stream таким образом, чтобы он дублировал все прочитанные байты список. Например, при чтении файла, каждый байт записывался в созданный ...
Alexandr Tsvetkov's user avatar
0 голосов
0 ответов
30 показов

C# Декорирование клсса Stream

Задача заключается в следующем: необходимо задекорировать класс Stream таким образом, чтобы он дублировал все прочитанные байты список. Например, при чтении файла, каждый байт записывался в созданный ...
Alexandr Tsvetkov's user avatar
0 голосов
1 ответ
96 показов

ffmpeg: Почему отключается трансляция из нескольких видео?

Здраствуйте, у нас есть 24/7 трансляция, которая крутит по кругу 5-6 видео, которые по 8 часов Для этой задачи мы взяли ffmpeg, написали простенький bash скрипт #!/usr/bin/bash #Standard Options ...
Danil Kalinin's user avatar
0 голосов
2 ответа
223 показа

Как запустить телеграм-бота из импортированной библиотеки?

Мне необходимо запускать несколько телеграм-ботов с одинаковым функционалом одновременно. Питон, библиотека telebot. Я хочу сделать это следующим образом: файл с програмой бота импортируется в ...
Mixam's user avatar
  • 31
0 голосов
0 ответов
135 показов

Как создать новый файл на чтение и на запись с помощью fstream?

[Solved] Как создать n файлов на чтение и на запись? Пробывал вот так, но не получается void createFiles(const std::string& fileName, const int filesCount){ vector<fstream*> files; ...
user21328241's user avatar
1 голос
1 ответ
93 показа

Почему не вызываются методы объекта из arraylist с помощью stream (кроме toString)?

Целый день пытаюсь разобраться с java stream, но не могу понять одной вещи. Есть класс SomeClass, в нем есть переопределенный public String toString() и есть другие методы, например, public void ...
В Т's user avatar
  • 71
0 голосов
1 ответ
50 показов

Почему в данном фрагменте кода происходит memory leak?

Почему в данном фрагменте кода происходи memory leak? Насколько я понимаю, то берётся копия потока, над ней выполняются операции, а затем в памяти "оригинальный поток" заменяется копией? ...
Alexandr Kruzer's user avatar
0 голосов
1 ответ
178 показов

Отправка файлов на сервер ASP.NET Core

Всем добрый день. Столкнулся с такой проблемой: при отправке файла на сервер, он просто не сохраняется. Что я делаю не так, вот пример кода: public async Task<IActionResult> UploadFile(...
Олександр Фалько's user avatar
0 голосов
1 ответ
256 показов

FFmpeg. Чтение и запись нескольких файлов из потока

Проблема следующая. Мне надо конвертировать видео в набор картинок через процесс ffmpeg. Раньше я успешно это делал при помощи следующего кода: public void VideoToImages1() { var inputFile ...
Stiven Diplet's user avatar
0 голосов
2 ответа
47 показов

Как использовать здесь метод chaining? Нужно решить это без создания полей, не разрывая цепочки методов

public static void main(String[] args) { Pattern selectWords = Pattern.compile("[^a-zA-Zа-яА-я0-9]+"); Scanner sc = new Scanner(System.in, "UTF-8").useDelimiter(selectWords)...
Bucksit's user avatar
  • 11
1 голос
2 ответа
236 показов

Как можно отфильтровать 2 колекции через Stream API, и в конечном итоге создать колекцию Обьектов исходя из данных

Method must return a list of NumberPair objects by the following rules: the first element of the pair belongs to integerList1; the second element of the pair belongs to integerList2; both elements ...
Алексей's user avatar
2 голоса
1 ответ
133 показа

Java как отследить сообщения выводящиеся на консоль

Пытаюсь написать некий "слушатель" для отслеживания сообщений которые выводятся в консоли. Есть класс который запускается в отдельном потоке и пишет сообщения, хотелось бы дождаться ...
p_redator's user avatar
  • 140
0 голосов
1 ответ
153 показа

Как в Java заменить (перезаписать) части файла? [дубликат]

Есть файл, надо в нём найти и заменить определённые части на другие (той же длины). Я понимаю, что можно построчно читать файл, для прочитанной строки делать замену и записывать её в другой файл, как ...
Eikthyrnir's user avatar
0 голосов
1 ответ
384 показа

c# отличие StreamReader от FileStream

Не могу понять, почему при private static GoogleCredential? _credential; private static readonly string[] _scopes = {SheetsService.Scope.Spreadsheets}; private static GoogleCredential GetCredential() ...
Humble Newbie's user avatar
2 голоса
2 ответа
245 показов

Как одним процессом писать в поток входных данных другого процесса(Или как узнать дескриптор потока вывода прцесса)

Пусть есть скомпилированная программа PR1, на языке с++, код которой выглядит так(Но этот код нам неизвестен, имеем только готовый бинарник): #include <iostream> using namespace std; ...
Space Researcher's user avatar
0 голосов
2 ответа
67 показов

Почему NullPointerException?

NoSuchFileException String path="C:\\Новая папка\\Документ Microsoft Word.docx"; List<String> list= Files.readAllLines(Path.of(path)); FileNotFoundException String path="...
Алексей's user avatar
0 голосов
1 ответ
71 показ

Из MemoryStream читается мусор

Исходные данные: 0xaa, 0xff, 0x01, 0x02, 0x04, 0x08, 0x10, 0x20, 0x40, 0x80 При чтении: 0x3F, 0x3F, 0x01, 0x02, 0x04, 0x08, 0x10, 0x20, 0x40, 0x3F Предположительно большие значения дают это. ...
Lesha Vel's user avatar
-2 голоса
1 ответ
205 показов

Не работает второе чтение из cin

Изучаю c++ по книге Бьёрна Страуструпа, задание следующее: Напишите программу. считывающую и сохраняюшую ряд целочис ленных значений, а затем вычисляющую сумму первых N чисел. За просите значение N. ...
Jora Yetti's user avatar
1 голос
0 ответов
95 показов

Почему в StreamWriter UTF-8 ведет себя по разному?

Возникло проблема с кодировками при записи в файл русского языка на C#. В чем суть: у меня есть строка с русскими и английскими символами закодированная в UTF8, я записываю ее в файл при двумя ...
Pedro's user avatar
  • 53
-1 голос
1 ответ
151 показ

Как отфильтровать Stream по году?

Нужно выбрать из рабочих одного с наивысшей зарплатой, устроившегося работать в 2017 году. В процессе два вопроса возникает: 1.Почему такой код не выводит ничего на экран? staff.stream().filter(d->...
Алексей's user avatar
0 голосов
1 ответ
22 показа

Почему после фильтрации в стриме выводится пустое поле

import java.util.ArrayList; import java.util.List; import java.util.stream.Collectors; public class Test2 { public static void main(String[] args) { Vehicle vh1 = new Vehicle("Audi ...
kreal0s's user avatar
12 голосов
1 ответ
284 показа

Алгоритм сжатия ДНК-последовательностей для хранения геномов на сервере с очень быстрой распаковкой

Встала необходимость держать ряд геномов на веб-сервере (различного рода утилиты для биоинформатиков, генетиков и биологов/медиков, в целом). А это, как оказывается, стало недешево :) Объёмы большие, ...
Viktor Tomilov's user avatar
1 голос
1 ответ
68 показов

Не удаляется файл java после распаковки

Уже задавал вопрос на эту тему, но, видимо, дал недостаточно информации/некорректно задал. У меня есть функция, в которую подаются 2 параметра: путь к архиву и директория его распаковки. После ...
Реинкарнация's user avatar
0 голосов
0 ответов
181 показ

Node.js стрим аудио потока

@Get("stream/:id/:name/:server") async bookStream( @ResponseDecorator() response: ServerResponse, @Request() request: ServerRequest, @Param("id", ParseStreamInfoPipe) ...
Chlenix's user avatar
  • 21
0 голосов
1 ответ
228 показов

Асинхронное копирование вкупе с progressBar'om

На самом деле задача на половину выполнена, я имею готовое решение не без помощи BackgroundWorker: Функция копирования: private void copy_file(string source_, string des) { FileStream fsOut = new ...
1001001's user avatar
  • 1,826
0 голосов
1 ответ
21 показ

Как добавить ко всем дубликатам в Map суффикс

Предположим, что на вход метода приходят айдишники, одни из которых имеют суффикс, а другие нет Set ids = [id, id::Suff] Далее мне нужно создать Map<String, Object>, где ключом будет id. Но ...
user504819's user avatar