stream 相关问题

在Java中将流转换为字符串

我想将 Map<> 的流转换为字符串，并将其附加到文本区域。我尝试了一些方法，最后一个使用 StringBuilder，但它们不起作用。 公开 我想将 Map<> 的流转换为字符串，并将其附加到文本区域。我尝试了一些方法，最后一个使用 StringBuilder，但它们不起作用。 public <K, V extends Comparable<? super V>> String sortByAscendentValue(Map<K, V> map, int maxSize) { StringBuilder sBuilder = new StringBuilder(); Stream<Map.Entry<K,V>> sorted = map.entrySet().stream() .sorted(Collections.reverseOrder(Map.Entry.comparingByValue())); BufferedReader br = new BufferedReader(new InputStreamReader((InputStream) sorted)); String read; try { while ((read=br.readLine()) != null) { //System.out.println(read); sBuilder.append(read); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } sorted.limit(maxSize).forEach(System.out::println); return sBuilder.toString(); } 您可以将条目收集到一个String中，如下所示： String sorted = map.entrySet().stream() .sorted(Collections.reverseOrder(Map.Entry.comparingByValue())) .map(e-> e.getKey().toString() + "=" + e.getValue().toString()) .collect(Collectors.joining (",")); 考虑对 @Eran 的代码进行轻微更改，因为 HashMap.Entry.toString() 已经通过 = 为您加入了： String sorted = map.entrySet().stream() .sorted(Collections.reverseOrder(Map.Entry.comparingByValue())) .map(Objects::toString) .collect(Collectors.joining(",")); 这很容易做到，您可以使用 Steams API 来做到这一点。首先，将映射中的每个条目映射到单个字符串 - 键和值的连接字符串。一旦你有了这个，你就可以简单地使用 reduce() 方法或 collect() 方法来做到这一点。 使用“reduce()”方法的代码片段将如下所示： Map<String, String> map = new HashMap<>(); map.put("sam1", "sam1"); map.put("sam2", "sam2"); String concatString = map.entrySet() .stream() .map(element-> element.getKey().toString() + " : " + element.getValue().toString()) .reduce("", (str1,str2) -> str1 + " , " + str2).substring(3); System.out.println(concatString); 这将为您提供以下输出： sam2 : sam2 , sam1 : sam1 您还可以使用 collect()' method instead ofreduce()` 方法。它看起来像这样： String concatString = map.entrySet() .stream() .map(element-> element.getKey().toString() + " : " + element.getValue().toString()) .collect(Collectors.reducing("", (str1,str2) -> str1 + " , " + str2)).substring(3); 两种方法给出相同的输出。

从函数流 std::sync::mpsc::Receiver 结果

如何从函数流式传输 std::sync::mpsc::Receiver 的内容？ 在所有结果可用之前，调用者应该能够收到结果。 理想情况下，我想要

将 PHP 响应逐字流式传输回 JS，而不保留完整历史记录

我想将 PHP 响应逐字流式传输到 JS，但是响应会被缓存： PHP 文件： 我想将 PHP 响应逐字流式传输到 JS，但是响应会被缓存： PHP 文件： <?php header('Content-Type: text/event-stream'); header('Cache-Control: no-cache'); ob_clean(); echo "Hello "; ob_flush(); flush(); sleep(2); ob_clean(); echo "World "; ob_flush(); flush(); sleep(2); ob_clean(); echo "!"; ob_flush(); flush(); ?> JS 文件： var httpllm = new XMLHttpRequest(); httpllm.onreadystatechange = function() { if(httpllm.readyState == 3) { console.log(httpllm.responseText); } } httpllm.open('POST', 'test.php', true); httpllm.send(); 结果： -> Hello -> Hello World -> Hello World ! 我想要什么： -> Hello -> World -> ! 我错过了什么，只发送/接收一个单词，而不是每次回复的完整历史记录？ 我通常使用 EventSource 处理 SSE 示例： var eventSource = new EventSource('sse.php'); eventSource.onmessage = function(event) { console.log(event.data); }; 这里 onmessage 单独处理每条消息！

如何使用axios向img html标签发出视频流http GET请求？

我有一个 Django 2.1 后端，它有一个视频流端点和一个 Vue-Cli3 作为我的前端。 我后端的视频流端点是 GET 请求。让流媒体在我的客户端工作......

如何在 Rust 中通过 Arc<Vec> 创建 Cursor（或其他 Read + Seek 对象）？

实际问题（避免A/B场景）： 我在 Arc 对象后面有一个很大的缓冲区： pub 结构体大数据 { 数据：弧>， } 我需要将 Read + Seek 版本传递给网络 API ...

Java 中的标准输入与命令行

虽然操作系统中的每个命令行进程都可能使用标准输入、标准输出和标准错误数据流，但我对命令行参数和标准输入感到困惑。 也许是我的

如何直接从url加载图像到node.js的缓冲区中

我想直接从互联网加载图像进行流式传输，而不将其保存到磁盘并再次加载。 就像是 fs.createReadStream(imageDirectory) 但仅适用于 URL。 我想给这个...

从EventStore读取流，没有“流不存在异常”

.net 编写的应用程序尝试使用 EventStore.Client.Grpc.Streams 23.1.0 读取事件流。逻辑如下： 尝试读取流 如果没有流（或流版本为0）我们...

写入流并同时发送到 .NET 中的 HTTP 控制器

我们有一个服务器 API 端点，可以将 HTTP Body 作为流读取并将其解析为非常大的实体集合。我们使用 JsonTextReader 实现了流的解析（Newtonsoft.Json 包...

Stream 转换为 0 字节

安装最新版本的 Visual Studio 2022 和 .NET 8.0 后，我在将流转换为文件（保存本地或上传到 FTP）时遇到问题。 到目前为止我一直在使用以下c...

如何使用 FFMPEG 流式传输桌面，并将输出设置为 http://127.0.0.1:8080

我正在尝试在Windows上使用FFMPEG通过我的本地主机地址流式传输我的整个桌面：127.0.0.1:8080，并且可以从同一网络中的另一台计算机使用vlc访问它

如果链接正在运行，如何在 flink-sql 作业图中可视化运算符执行情况

我有flink-sql应用程序，它只是通过连接多个表来执行简单的简单插入到丰富表中。 创建表T1（...）WITH（'连接器'='upsert-kafka'，'主题'='T1'，...） ...

如何从 HTML 文件输入中读取文件作为 ReadableStream？

我有使用 ReadableStream 运行文本文件的代码，并在其中找到一些日志行。目前，这对我来说适用于 Node.js 后端的 fetch API 和 FileHandle.readWebStream...

Visual Studio 2019：C++ 流实现中的奇怪行为

考虑以下简单的streambuf实现： #包括 #包括 类 mystreambuf ：公共 std::streambuf { int_type 下溢() 覆盖 {

Android Gstreamer 启动 rtmpsink 后本地显示视频滞后

我正在开发Android应用程序 我在 rtsp 流中有传入视频源（ h265/hevc ） 源 rtsp 服务器有问题只允许一个连接 我想播放 rtsp 流，也想流式传输...

如何将 Png 或 Jpeg 转换为 Tiff？

我正在尝试将 Png 或 Jpg 文件转换为 Tiff 格式。这是我的代码： ' 如果是 png 或 jpeg，则转换为 Tiff If aFName.ToUpper.EndsWith(".PNG") OrElse aFName.ToUpper.EndsWith(&...

客户端写入字节数少于预期

我正在尝试使用 C++ 中的 UDP 套接字在客户端和服务器之间发送数据，作为我大学中的一个项目。我尝试发送的文件是一个名为 s.html 的 HTML 文档。这是 1,814,247 字节...

蜂鸟回声测深仪多播流数据监听c#

朋友们，美好的一天 我正在尝试为我的回声测深仪 humminbird helix 9 编写应用程序，以实时接收来自它的数据。 我已经通过路由器连接它并使用 wire shark 我发现它传输数据...

Raspberry pi 直播到 YouTube 停止工作

我有一个工作设置，可以使用我的树莓派 3 将视频流式传输到 youtube。 直到昨天才开始工作。没有任何改变，但当我尝试启动流时出现错误。 运行以下命令

Flutter Firestore 查询侦听器在 Firebase 模拟器中运行时重叠

我有一个 Flutter 小部件，可以监听 2 个 Firestore 查询： 类 ExampleWidget 扩展 StatefulWidget { const ExampleWidget({super.key}); @覆盖 状态 createState()...