stream 相关问题

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

ESP32 JPEG 视频流的重新串流

我正在使用 30 个 ESP32 AI Thinker 摄像头构建 DIY 家庭监控系统。为了加入和管理所有这些，我创建了一个 NodeJS 的 Web 应用程序 - 一个用于查看所有摄像头、添加/编辑/删除它们的仪表板。呃...

node.js stream esp32 mjpeg

回答 1 投票 0

在 NodeJS 中，数据未在消费者中作为块（流）接收

我有两个服务生产者和消费者。 Producer 在服务器中有很大的 json 文件。我想通过rest api通过网络提供服务，并且我使用nodejs流技术来加载内存中的字节...

node.js json stream data-processing producer

回答 1 投票 0

如何在 Java Spring 上等待订阅者完成 TEXT_EVENT_STREAM

使用返回字符串的 Stream API，我希望有一个函数可以在单个字符串上返回它们，并用分隔符分隔，当前使用订阅并附加到列表使用返回字符串的 Stream API 时，我想要一个函数将它们返回到由定界符分隔的单个字符串上，当前使用订阅并附加到列表，但显然，因为异步不会等待它准备好返回该功能之前。如何实现非异步方法？ private String executeStream(String streamId, UserToken currentUserAndToken) { List<String> combinedString = new ArrayList<String>(); URI streamUri = UriComponentsBuilder.newInstance() .scheme("https") .host(host) .path(streamPath) .buildAndExpand(streamVariablesMap) .toUri(); webClientt.get() .uri(streamUri) .headers(h -> h.setBearerAuth(currentUserAndToken.getToken())) .accept(MediaType.TEXT_EVENT_STREAM) // for Server-Sent Events (SSE) .retrieve() .bodyToFlux(String.class) // convert the response body to a Flux .subscribe(data -> combinedString.add(data)); // < --- Here I want to combine all Data into single string return String.join(", ", combinedString); } 使用 .blockLast() 代替 .subscribe() 它将阻塞，直到你读完所有。这将使您的呼叫同步。请参阅https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#blockLast--

java spring spring-boot stream

回答 1 投票 0

如何迭代列表<List<String>>并创建单个列表？

我正在开发一个遗留代码，其中有一个ListstudentList。每个学生对象包含两个属性字符串名称；列出地址；类地址包含两个属性我正在开发一个遗留代码，它有一个 List<Student> studentList。每个学生对象包含两个属性 String name; List<Address> address; 类 Address 包含两个属性 houseNumber 和 streetNumber 我想创建一个包含 name, houseNumber, streetNumber 的单个列表。 houseNumber 是一个枚举，所以我将执行 .toString() 和 if 空值条件。 final List<String> finalList = new ArrayList<>(); studentList .forEach(x -> { x.getAddressList() .forEach(y -> { finalList.add(x.getName); finalList.add(y.getHouseNumber != null ? y.getHouseNumber.toString() : ""); finalList.add(y.getStreetNumber); }); } ); 我已经编写了这段代码，但我希望它通过使用平面地图来实现结果。任何帮助将不胜感激为每个学生创建一个名称流和一个包含每个 Adress´s houseNumber 和 streetNumber 的平面映射流，连接此流和平面映射并最终收集： List<String> finalList = studentList.stream() .flatMap(student -> Stream.concat( Stream.of(student.getName()), student.getAddress().stream().flatMap(address -> Stream.of(address.getHouseNumber() != null ? address.getHouseNumber().toString() : "", address.getStreetNumber())))) .collect(Collectors.toList()); 你想要这个吗： var rs = lst.stream().flatMap(x -> x.getAddress().stream() .map(y -> List.of(x.getName(), y.getHouseNumber() != null ? y.getHouseNumber().toString() : "", y.getStreetNumber()) )).collect(Collectors.toList()); rs 是包含姓名、房屋号码、街道号码的列表。您可以使用 Java Stream API 来执行此操作。我还不明白您到底想要获得什么结果，因此在下面的示例中，我将不同的部分连接成一个字符串。（有关更多信息，请查看官方 API：https://docs.oracle.com/en/java/javase/12/docs/api/java.base/java/util/stream/Stream.html#flatMap(java .util.function.Function)): studentList.stream() .map(l -> l.getAddressList()) .flatMap(Collection::stream) .map(y -> y.getName() + " " + (y.getHouseNumber() != null ? y.getFieldResultStatus().toString() : "") + " " + y.getStreetNumber()); }) .collect(Collectors.toList()); List<String> list = students.stream() .flatMap(student -> student.getAddress().stream() .flatMap(address -> Stream.of( student.getName(), Objects.toString(address.getHouseNumber(), ""), address.getStreetNumber() ))) .toList(); 根据要求，这将返回一个扁平列表，重复学生拥有的每个地址的每个学生姓名和门牌号： students[0].name students[0].address[0].houseNumber students[0].address[0].streetNumber students[0].name students[0].address[1].houseNumber students[0].address[1].streetNumber … students[n].name students[n].address[m].houseNumber students[n].address[m].streetNumber

java stream flatmap

回答 4 投票 0

在节点中，可读文件流只是“底层”的缓冲异步读取吗？

我想知道，如果我要深入研究流代码，我是否会发现，对于可读文件流来说，基本上发生的事情是数据被异步读入缓冲区......

node.js stream buffer file-access

回答 1 投票 0

@ServiceActivator(inputChannel = "[topic].[group].errors") 注释会导致“是否存在无法解析的循环引用异常？”

使用处理本地异常的通道时发生异常，但工作正常。 @ServiceActivator(inputChannel = "force-logout-topic.force-logout-group.errors") 公共空间

java spring stream spring-integration

回答 1 投票 0

如何使用java中的流API添加两个列表中的每个元素

partnersName =["partner1","partner2"]; 总日期 = ["2022-05-18","2022-05-19"]; 两个列表都只存储字符串这是下面的代码，它给了你...