stream 相关问题

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

如何将Flux<Object>列表转换成List<Object&gt。

我有一个Flux,我想把它转换为List。我怎么做呢?Flux getInstances(String serviceId); --> Current one List getInstances(String serviceId); --> Demanded one Java 8 or reactive ...

回答 1 投票 0

当尝试使用 stream.PassThrough 上传到 Amazon S3 时,不支持 body payload 对象。

在没有为我找到这个问题的有效解决方案后,我把我的Angular代码粘贴过来。Component const pipeline = this.syncService.uploadSong(localPath, filename); pipeline.on('close', (...)。

回答 1 投票 0

在Swift 5中串流麦克风音频

我的两台IOS设备之间有一个工作连接。从一个摄像头向另一个设备发送实时流的工作。但现在我想发送麦克风音频,这不工作。我没有得到任何错误,但我只是...。

回答 1 投票 0

在Stream.map中没有调用put方法

我有一个下面的代码,但没有达到预期的效果,所以我需要一点帮助。我有一个Set 确认集, 列表 进口清单、地图

回答 1 投票 0

在java 8中不改变大小写的情况下过滤唯一的单词

我想用java 8用不区分大小写的方法过滤列表中的唯一元素。例如:1)输入。Goodbye bye Bye world world WorlD Output: Goodbye bye world 2) 输入:Sam went went to ..: Sam went went to to ...

回答 1 投票 0

在带有比较器的Lambda表达式中的stream min()和max()方法,只返回第一个和最后一个元素,不返回minmax元素。

在带比较器的Lambda表达式中,流min()和max()方法只返回第一个和最后一个元素,不返回minmax元素。有谁能解释一下min()和max()的工作原理。 公 ...

回答 1 投票 -2

异步写入文件

我在代码中实现async方法时遇到了一个小问题,因为这是我第一次使用它。我在向文件写入时遇到了问题,当我将方法设置为同步时,它可以正常工作,但是, ...

回答 2 投票 0

在dart中把未来函数转换为流函数

我想把Stream从Future中删除......请问如何改变Stream中的Future。例如,返回 "未来电影 "的函数:Future < Movie > 如何在Stream中改变 "未来"?Future < Movie > getMovieDetails(int id) async { Movie m = ...。

回答 1 投票 0

有人创建了一个程序来手动清除雪花中的流吗?

我正在寻找一段代码,这段代码将导致一个流清空,本质上是重置它。下面是一个用例。我们使用流来跟踪类型2维表到数据集市的变化。

回答 2 投票 -1

Kafka流在控制中心不显示输出。

我正在通过Confluent平台快速入门(Docker)。我可以创建一个主题,用kafka-node发布消息,用kafka-console-subscribe.sh订阅,还可以在KSQL中CREATE STREAM ...。

回答 1 投票 0

我想用java streams在对象内部做一个列表或列表映射。

在阅读 "Java 8 In Action "时,我创建了一个真实的练习。我有一个对象,里面有List,我想把这个对象和List中的元素的流进行分组。例子:我有一个对象,里面有List,我想用List中的元素对这个对象进行组流。Beverage cola = new ...

回答 1 投票 0

如何在ffmpeg中禁用字幕解码?

我试图用FFMpeg将一些包含视频、音频和字幕流的视频文件转换为另一种格式。但是,ffmpeg抱怨字幕格式--不能解码流......。

回答 2 投票 25

如何在Flutter中实时监听firebase的更新。

我有一个从firebase读取用户数据的流。我在登录后触发它,它工作得很完美。我把数据显示在我的appbar中。当我手动更新firebase的时候,我想立即看到新的日期。

回答 2 投票 0

附加二进制文件

我正在将对象附加到二进制文件。我的文件是:File f = new File(“ person.dat”);尝试尝试时出现错误(java.io.StreamCorruptedException:无效的流头:79737200)...

回答 1 投票 1

确定地基于另一个流的Flink筛选器流

我在Flink中有2个数据流(具有常见的时间戳记,来自Kafka),其中一个包含一些信号值,另一个包含活动性(简单的活动-非活动)信息。我...

回答 2 投票 0

Java收集返回顶级项目的嵌套地图流

我有以下模型:class Item {字符串名称; ... List 子项; }类SubItem {字符串名称; ...列表 ids; }对于... ] >>

回答 1 投票 0

如何用Java 8中的流替换循环

我正在使用以下方法,需要在Java 8中使用流和lamda。public static void addMemberships(final int key,MembershipData [] Members)throws SpiderException {HashMap ] >>

回答 1 投票 -1

如何将庞大的结果集从数据库导出到多个csv文件中,并即时压缩它们?

我发现了一个非常不错的代码,可以将数据库中的大量行导出到多个csv文件中并将其压缩。我认为这是一个可以帮助很多开发人员的不错的代码。您可以找到整个示例...

回答 1 投票 0

如何从数据库导出大量结果集并导出多个csv文件并进行压缩?

我发现了一个非常不错的代码,可以将数据库中的大量行导出到多个csv文件中并将其压缩。我认为这是一个可以帮助很多开发人员的不错的代码。您可以找到整个示例...

回答 1 投票 0

Flutter Dio软件包:如何收听另一个类的下载进度?

我有一个DownloadsService类,该类使用dio软件包处理文件的下载。我想听我的ViewModel类的下载进度,该类在我的...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.