stream 相关问题

流是一系列可以以串行方式访问的数据元素。对于Java 8的新Stream API，请改用java-stream标签。

Dart流控制器如何实现并发

假设我有一个 StreamController，我想使用这个控制器添加事件来处理来自应用程序的多个请求（并行）。我所实现的内容如下：在main.dart中菲...

flutter dart stream streamcontroller

回答 1 投票 0

OpenAI 的 API 中流式传输如何工作？

我对事件流的工作原理有基本的了解。我目前正在将 langchain 代码转换为直接使用 OpenAI 的 API，我有一段代码我有点困惑。 defstream_messag...

python stream openai-api server-sent-events chatgpt-api

回答 1 投票 0

为什么 AVPlayer 在同一个会话中询问多个联合范围？

我想知道为什么 AVPlayer 会问请求中的联合范围。例子： 1.我们有良好的无线网络连接。 2. 轨道总长度 = 1000000。首先 AVPlayer 会询问 bytes=0-1 - 没关系，它 j...

ios stream http-headers avplayer

回答 1 投票 0

使用 WebAudio 合并/混合两个音频流

我有一个来自 navigator.getUserMedia 的 MediaStreamSource，它连接到 GainNode，而 GainNode 又连接到 ScriptProcessorNode，如下所示： [获取用户媒体流] -> [

javascript html audio stream webrtc

回答 3 投票 0

如何加密视频流[重复]

可能的重复：视频文件加密？我想使用流密码加密视频流并将其发送到客户端 PC，客户端 PC 可以在其中即时播放它。问题：什么类型...

java encryption video stream

回答 1 投票 0

无法使用 CrypoStream 访问封闭流

我正在使用 .NET Framework 4.5 构建文件加密器/解密器实用程序，但是当我完成使用 CrypyoStream 写入目标流时，该实用程序会将文件写入磁盘或存储...

vb.net encryption stream

回答 1 投票 0

是否可以通过某种方式执行异步代码以写入流？

我写了一些WPF编辑器，它显示文本。但文本存储在 Stream 中。所以，这里是 XAML 代码：我写了一些WPF编辑器，它显示文本。但文本存储在 Stream。所以，这里是 XAML 代码： <TextBox Text="{Binding ObjectViewModel.Text,Mode=TwoWay,UpdateSourceTrigger=PropertyChanged}" /> 我将 UpdateSourceTrigger 设置为 PropertyChanged，因为用户可以在此编辑器中读取和写入一些文本；这里读取和写入文本（作为流）的代码： public String Text { get { var sr = new StreamReader(StreamObject.text, Encoding.UTF8, true); return sr.ReadToEnd(); } set { lock (_lockObject) { var str = value; var textStream = new MemoryStream(); using (var writer = new BinaryWriter(textStream, Encoding.UTF8, true)) { writer.Write(Encoding.UTF8.GetBytes(str)); } textStream.Position = 0; StreamObject.text = null; StreamObject.text = textStream; textStream.Close(); } } } 因此，当用户输入新的字代码时，写入流新数据（清除旧流并创建新数据）。但它的性能很慢。我应该使用async（以某种方式）或其他方法来提高性能吗？我知道，可以使用 LostFocus 属性，但这样用户应该失去 TextBox 的焦点。我应该使用异步（以某种方式）或其他方法来提高性能吗？确实有一个 async 版本的 ReadToEnd 方法，称为 ReadToEndAsync 但它实际上不会使你的代码更快，并且你不能从属性调用它，因为属性不能标记为 async。每次更改属性时，在源属性的 getter 和 setter 中创建新的 Stream 是没有意义的。您应该从流中读取once，例如在视图模型的构造函数或命令的 Execute 方法中，然后设置 string 属性的值。然后，在您实际需要将其保存到数据库时，将 string 转换回流 once，例如： class ViewModel { public ViewModel() { using (var sr = new StreamReader(StreamObject.text, Encoding.UTF8, true)) Text = sr.ReadToEnd(); } //this method is called when your "Save" button or similar is clicked public void SaveToDb() { lock (_lockObject) { var str = value; using (textStream = new MemoryStream()) { using (var writer = new BinaryWriter(textStream, Encoding.UTF8, true)) { writer.Write(Encoding.UTF8.GetBytes(str)); } textStream.Position = 0; StreamObject.text = null; StreamObject.text = textStream; } } } public String Text { get;set; } } 源属性本身不应该知道有关流的任何信息。

c# wpf stream

回答 1 投票 0

使用 Files.lines(Paths.get(file1)) 读取文件也会读取空白行。如何删除空白行？

我有一个 CSV 文件，其中有 2 行。我用了字符串 file1 ="C:\sample.csv"; Streamlines = Files.lines(Paths.get(file1)) { 读取文件中的行，但看起来我...

java lambda java-8 stream java-stream

回答 3 投票 0

iperf3：无法创建新流

我的系统上有 2 个用户。一名用户能够提供系统上安装的 iperf3 的所有日志。但第二个用户给出的错误为： iperf3：错误 - 无法创建新流：没有这样的 fi...

sockets tcp stream udp iperf3

回答 4 投票 0

将并行增量嵌套循环转换为流

我正在尝试将以下 Groovy for 循环转换为 Java 流。 def a = [12,34,5,64,24,56], b = [1,23,45] for(int i=0;i 我正在尝试将以下 Groovy for 循环转换为 Java 流。 def a = [12,34,5,64,24,56], b = [1,23,45] for(int i=0;i<a.size();) for(int j=0;j<b.size() && a[i];j++) println a[i++]+","+b[j] 输出： 12,1 34,23 5,45 64,1 24,23 56,45 我尝试了几种方法，但我不确定如何从内循环增加外循环。任何指导表示赞赏。以下代码是我做过的最远的代码。 a.stream().forEach({x -> b.stream().filter({y-> y%2 != 0}).forEach({ y-> println x+","+y }); }); 输出： 12,1 12,23 12,45 34,1 34,23 34,45 5,1 5,23 5,45 64,1 64,23 64,45 24,1 24,23 24,45 56,1 56,23 56,45 IntStream.range(0, left.length) .mapToObj(x -> left[x] + " " + right[x % right.length]) .forEachOrdered(System.out::println); 其中 left 是 a 且 right 是 b 撇开命令式解决方案的索引细节不谈，这个问题可以看作是迭代两个列表的连续元素，根据需要重复第二个列表。第三方 Google Guava 库提供了 Streams.forEachPair 方法来迭代两个流的连续元素。 Streams.forEachPair( a.stream(), Stream.generate(b::stream).flatMap(s -> s), (a1, a2) -> System.out.println(a1 + "," + a2)); Stream.generate(b::stream).flatMap(Function.identity())调用会重复生成b元素的无限流。当较短的流耗尽时，Streams.forEachPair停止，因此它将迭代a的所有元素，以及来自b的相同数量的元素（重复）。

groovy stream java-stream iteration

回答 2 投票 0

指南：将并行增量嵌套循环转换为流

我正在尝试将以下循环转换为Java流。 def a = [12,34,5,64,24,56], b = [1,23,45] for(int i=0;i 我正在尝试将以下循环转换为Java流。 def a = [12,34,5,64,24,56], b = [1,23,45] for(int i=0;i<a.size();) for(int j=0;j<b.size() && a[i];j++) println a[i++]+","+b[j] 输出： 12,1 34,23 5,45 64,1 24,23 56,45 我尝试了几种方法，但我不确定如何从内循环增加外循环。任何指导表示赞赏。以下代码是我做过的最远的代码。 a.stream().forEach({x -> b.stream().filter({y-> y%2 != 0}).forEach({ y-> println x+","+y }); }); 输出： 12,1 12,23 12,45 34,1 34,23 34,45 5,1 5,23 5,45 64,1 64,23 64,45 24,1 24,23 24,45 56,1 56,23 56,45 IntStream.range(0, left.length) .mapToObj(x -> left[x] + " " + right[x % right.length]) .forEachOrdered(System.out::println); 其中 left 是 a 且 right 是 b 撇开命令式解决方案的索引细节不谈，这个问题可以看作是迭代两个列表的连续元素，根据需要重复第二个列表。第三方 Google Guava 库提供了 Streams.forEachPair 方法来迭代两个流的连续元素。 Streams.forEachPair( a.stream(), Stream.generate(b::stream).flatMap(s -> s), (a1, a2) -> System.out.println(a1 + "," + a2)); Stream.generate(b::stream).flatMap(Function.identity())调用会重复生成b元素的无限流。当较短的流耗尽时，Streams.forEachPair停止，因此它将迭代a的所有元素，以及来自b的相同数量的元素（重复）。

groovy java-8 stream iteration java-stream

回答 2 投票 0

使用 Web Streams，如何区分可读流是否被压缩（gzip）？

我有一个客户端 JS 应用程序，我想在其中使用 Web Streams 处理用户的一些输入文件。该文件可以是文本文件（在这种情况下，我只需通过

javascript stream compression web-stream

回答 1 投票 0

使用 ReadableStream 作为请求正文进行获取

我正在尝试将 fetch 与 ReadableStream 一起使用。在此示例中，ReadableStream 应该简单地无限期地重复“Some data...”。拿来（'/'， { 方法：'POST'，正文：新的 ReadableStream({

stream fetch-api whatwg-streams-api

回答 2 投票 0

如何停止 GNU make 缓冲 Python 输出？

以下示例 Python 程序打印更新进度条。进度.py：导入系统导入时间对于范围（100）内的 i： sys.stdout.write(" %3d%%" % (i + 1)) sys.stdout.flush()