stream

1热度

2回答

我有一个网站将大文件发布到我的服务器。我需要逐行读取它，或者至少能够分割它。它有2000页长。现在，我有： if (file != null && file.ContentLength > 0) { using (file.InputStream) { //Looking for this part }

0热度

1回答

无法实现转换流

我需要创建一个读取文档的程序，对其进行加密并将结果写入另一个文档。所有这些都应该使用变换流完成。 Here's我的代码： "use strict"; const fs = require("fs"); const crypto = require("crypto"); const Transform = require("stream").Transform; // Make read

2热度

2回答

Akka流 - 按流中元素的数量进行过滤

我正在Scala编写应用程序，我正在使用Akka流。在某一点上，我需要过滤掉N个元素少于N个的流。因此，例如，与N=5： Source(List(1,2,3)).via(myFilter) // => List() Source(List(1,2,3,4)).via(myFilter) // => List() 将成为空流， Source(List(1,2,3,4,5)).via(my

0热度

1回答

排序数字，因为我从流中动态获取它们

我应该使用什么算法对数字进行排序（在数组中），因为我动态地从流中获取数字？我应该只是创建一个哈希，然后合并排序？

1热度

1回答

C＃SSHNet失败，在阅读和使用SftpClient

写我试图读取SftpClient /写文本在localhost： try { AuthenticationMethod authenticationMethod = new PasswordAuthenticationMethod("user", "password"); ConnectionInfo connection = new Connectio

0热度

1回答

生成一个DES密钥并通过Java中的套接字传递它

有人可以帮助我找出我的非常简单的程序中的问题吗？当在服务器上输出消息时，我想看到通过网络发送的相同消息，但我没有收到消息。这里是我的客户端代码： package encryption; import java.io.*; import java.net.*; import java.security.*; import java.util.*; import javax.crypt

0热度

1回答

如何管理卡夫卡组的过期

我试图通过删除它重置消费者配置并让我的脚本稍后重新创建它，但是我遇到了新消费者不能删除的错误。 [email protected]:~$ ./bin/kafka-consumer-groups.sh --bootstrap kafka-0:9092 --delete --group etl Option '[delete]' is only valid with '[zookeeper]'. N

-1热度

1回答

Java流间隙总和

稍微上下文：我试图通过获取键输入时刻之间的平均差异来检测条形码扫描器信号（此模型在打印扫描值后按下输入键）。最近我一直在寻找关于Java 8的Subramanian讨论，所以我不明白如何将此循环转换为流。 List<Instant> instants = new ArrayList<>(); content.addEventFilter(KeyEvent.KEY_RELEASED, e->{

1热度

2回答

如何将字节推回到Rust中的Read实现类型？

在标准库中是否存在支持向数据流中“推送”字节的流类型Read，以便随后的读取将在数据流中的其他字节之前首先返回所述字节？ n = stream.read(&mut buf).unwrap(); if ... { stream.???PUT_BACK???(&buf[..n]) }

1热度

1回答

http.ServeFile和http.ServeContent无法处理多个客户端

场景我使用golang创建了一个简单的视频流。首先，我使用来为我的视频提供服务。它一直工作，直到我同时连接4个选项卡到我的服务器，但前两个只能工作，其余的都不加载。我可以在播放两个视频的同时导航到菜单，但我无法播放其他视频。我也尝试过使用多个设备。只有两个连接可以传输。因此，我将更改为http.ServeFile但它仍然相同，但是当我使用io.Pipes时，它服务于每个请求，但问题是它