草庐IT

io-Stream

全部标签

java - 如何逐条读取一个 Stream?

JavaStream.forEach函数有一个严重的限制,即它的消费者不可能抛出已检查的异常。因此,我想一个一个地访问Stream的元素。我想做这样的事情:while(true){OptionaloptNewString=myStream.findAny();if(optNewString.isPresent())doStuff(optNewString.get());elsebreak;}然而,findAny是短路端子操作。也就是说,它关闭流。这段代码会在while循环的第二次迭代时崩溃。我不能简单地将所有元素放在一个数组中,然后一个一个地遍历该数组,因为可能有数千万个元素。请注意,

Java Stream API如何改进表达

我有以下代码:publicListgetEntriesForUserId(intuserId){Useru=DataBaseConnector.getAllUsers().stream().filter(user->user.getUserId()==userId).findFirst().orElse(newUser(-1,"Error");returnu.getEntries();}getEntries()返回List.如何将return语句添加到此lambda表达式中?就像是.map(User::getEntries)? 最佳答案

java - 使用浏览器打开 URLs - RoboVM/iOS

我有一款使用LibGDX的安卓游戏。在其中,我有一些用于在浏览器中打开URL的按钮:Intentintent=newIntent(Intent.ACTION_VIEW,Uri.parse("http://myURL/"));startActivity(intent);这似乎工作正常......问题是我正在尝试将游戏移植到带有RoboVM的iOS上运行,但不知道如何设置类似的东西。对于RoboVM绑定(bind),我假设我可能想要使用openURL()方法:openURL(UIApplicationapplication,NSURLurl,StringsourceApplication,

java - 使用 Commons IO 将目录压缩成一个 zipfile

我是Java编程的初学者,目前正在编写一个必须能够压缩和解压缩.zip文件的应用程序。我可以使用以下代码使用内置的Javazip功能和ApacheCommonsIO库解压缩Java中的zip文件:publicstaticvoiddecompressZipfile(Stringfile,StringoutputDir)throwsIOException{if(!newFile(outputDir).exists()){newFile(outputDir).mkdirs();}ZipFilezipFile=newZipFile(file);Enumerationentries=zipFil

Java servlet 和 IO : Create a file without saving to disk and sending it to the user

我希望可以帮助我解决文件创建/响应问题。我知道如何创建和保存文件。我知道如何通过ServletOutputStream将该文件发送回用户。但我需要的是创建一个文件,而不是将其保存在磁盘上,然后通过ServletOutputStream发送该文件。上面的代码解释了我拥有的部分。任何帮助表示赞赏。提前致谢。//ThisCreatesafile//Stringtext="Thesedaysrunawaylikehorsesoverthehill";Filefile=newFile("MyFile.txt");Writerwriter=newBufferedWriter(newFileWrit

带有 paho 的 java.io.EOFException

我想对mosquitto进行压力测试,所以我创建了一些代码如下for(inti=0;i但是,我在运行期间遇到了一些错误,例如EOFException并且某些客户端断开连接。我想知道一台mosquitto服务器可以同时发布多少个客户端消息,压力测试如何进行。谢谢!详细异常是:Connectionlost(32109)-java.io.EOFExceptionatorg.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:162)atjava.lang.Thread.run(Thread.java

java - 使用 Java 8 Stream API 将 List<X> 聚合到 List<X>

我有以下类(class):classMoney{CurrencyUnitcurrencyUnit;BigDecimalamount;}在我的应用程序中,我得到了一些随机列表Money对象:currencyUnit|amount---------------------EUR|5.1EUR|0USD|1.09EUR|42USD|3现在我想使用Java8StreamAPI来创建以下结果(只需为每个currencyUnit的数量调用BigDecimal::add):currencyUnit|amount---------------------EUR|47.1USD|4.09我已经知道/做过

Java 8 Stream - 为什么过滤器方法不执行?

这个问题在这里已经有了答案:WhydoesJava8Streamgeneratenothing?(3个答案)关闭6年前。我正在学习使用java流进行过滤。但是过滤后的流没有打印任何东西。我认为过滤器方法没有被执行。我的过滤代码如下:Stream.of("d2","a2","b1","b3","c").filter(s->{s.startsWith("b");System.out.println("filter:"+s);returntrue;});没有编译错误,也没有异常。有什么建议吗?

java - Stream 分组后不保留顺序

我有一个列表名称availableSeats我正在按blockIndex属性进行排序和分组,如下所示:availableSeats.stream().sorted(Comparator.comparing(SeatedTicketAssignment::getBlockIndex)).collect(Collectors.groupingBy(SeatedTicketAssignment::getBlockIndex)).forEach((block,blockAssignments)->{//Restofthecode}问题是分组依据的结果没有按照blockIndex排序。

java - Groovy:什么是 java stream anyMatch 的模拟

以下操作的Groovy模拟是什么?list.stream().anyMatch(b->b==0); 最佳答案 您的意思是查找列表是否包含元素0?deflist=[0,1,2,3,4]defresult=list.any{it==0}printlnresult您可以快速在线试用demo 关于java-Groovy:什么是javastreamanyMatch的模拟,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.