草庐IT

test_Stream

全部标签

Java8 : Stream map two properties in the same stream

我有一个类Model具有以下签名:classModel{privateStringstringA;privateStringstringB;publicModel(StringstringA,StringstringB){this.stringA=stringA;this.stringB=stringB;}publicStringgetStringA(){returnstringA;}publicStringgetStringB(){returnstringB;}}我想映射一个List到List在单个流中同时包含stringA和stringBListstrings=models.str

列表中列表的Java 8 Stream过滤值

我有一个如下所示的对象classMyObject{Stringtype;ListsubTypes;}给定一个MyObject列表,是否可以使用Java8流来过滤类型和子类型?目前为止myObjects.stream().filter(t->t.getType().equals(someotherType).collect(Collections.toList());但在此范围内,我还希望对每个子类型进行另一个过滤器,以过滤特定子类型上的那些。我不知道该怎么做。一个例子是myObject{type:A,subTypes[{X,Y,Z}]}myObject{type:B,subTypes[

对象数组的Java Stream Reduce

我有一个包含2个对象的数组列表:List其中object[0]是一个整数,object[1]是一个字符串。如何流式传输列表并对每个对象应用不同的函数?因此,结果将是一个数组:result[0]=multiplicationofallobject[0]result[1]=concatenationofallobject[1] 最佳答案 您可以使用reduce()实现此目的:publicvoidtestStacko(){Listlist=newArrayList();list.add(newObject[]{1,"foo"});list

java - 过滤 Stream 中的 Null 项目

使用JavaStream时,映射后有时会出现空值。目前,当需要省略这些值时,我使用:.stream()..filter(element->element!=null).为了更实用的样式,可以快速编写一个小的辅助方法:publicstaticbooleannonNull(Tentity){returnentity!=null;}这样您就可以使用方法引用来代替:.stream()..filter(Elements::nonNull).我找不到这样的jdk方法,尽管我怀疑他们已经包含了一个。这里有不同的方法吗?还是他们出于某种原因忽略了这一点? 最佳答案

java - 了解 Stream API ForEach Task 中的主循环

似乎JavaStreams并行化的核心是ForEachTask。理解其逻辑似乎对于获得必要的心智模型至关重要,该心智模型可以预测针对StreamsAPI编写的客户端代码的并发行为。然而,我发现我的预期与实际行为相矛盾。作为引用,这里是关键的compute()方法(java/util/streams/ForEachOps.java:253):publicvoidcompute(){SpliteratorrightSplit=spliterator,leftSplit;longsizeEstimate=rightSplit.estimateSize(),sizeThreshold;if((

java - "distributed unit testing"的框架或工具?

关闭。这个问题不符合StackOverflowguidelines.它目前不接受答案。我们不允许提问寻求书籍、工具、软件库等的推荐。您可以编辑问题,以便用事实和引用来回答。关闭5年前。Improvethisquestion是否有任何工具或框架能够更轻松地测试用Java编写的分布式软件?我的被​​测系统是一个点对点软件,我想使用类似PNUnit的东西进行测试。,但使用Java而不是.Net。被测系统是我正在开发的用于构建P2P应用程序的框架。它使用JXTA作为一个较低的子系统,试图隐藏它的一些复杂性。它目前是一个学术项目,所以我现在追求简单。在我的测试中,我想证明一个点(在它自己的进程中

java - Surefire Maven 插件 : "Corrupted STDOUT by directly writing to native stream in forked JVM"

我的JUnit测试在通过Maven和Surefire插件(下面的版本信息)运行时失败了。我看到错误消息:CorruptedSTDOUTbydirectlywritingtonativestreaminforkedJVM4.SeeFAQwebpageandthedumpfileC:\(...)\target\surefire-reports\2019-03-20T18-57-17_082-jvmRun4.dumpstreamFAQ页面指出了一些可能的原因,但我不知道如何使用这些信息来开始解决这个问题:CorruptedSTDOUTbydirectlywritingtonativestre

java - "No information about coverage per test."来自带有 Jacoco Ant 构建的 Sonar

我正在使用Ant、Jacoco和Sonar。当我运行构建时,Sonar告诉我“没有关于每次测试覆盖率的信息”。Sonar仪表板有我的覆盖结果,但我无法深入查看它们以查看代码。然而,由Jacoco生成的HTML报告确实包含深入代码。这是我的报道任务:我的Sonar目标看起来像这样:有人知道我错过了什么吗? 最佳答案 看起来您还没有设置“sonar.tests”属性来告诉Sonar在哪里可以找到单元测试的源代码。参见http://docs.sonarqube.org/display/SONAR/Analysis+Parameters.大

java - 嵌入式 Cassandra : Cannot run unit tests

我正在使用EmbeddedCassandraServerHelper执行单元测试。这是我的pomorg.apache.nifinifi-api1.4.0org.apache.nifinifi-utils1.4.0org.apache.nifinifi-mock1.4.0testorg.slf4jslf4j-simple1.7.25testjunitjunit4.8.2testcom.jcraftjsch0.1.54com.google.code.gsongson2.8.2org.mockitomockito-core1.10.8com.datastax.cassandracassand

Java Stream GroupingBy 在自定义对象中收集

我有温度等级classTemperature{doubleminTemp;doublemaxTemp;Stringcity;Stringcountry;}我有另一个维护温度集合的类classTemperatures{Listtemperatures;}我想使用流按countryName对温度进行分组。我想要的是publicMaptemperaturesByCountry()但是我无法使用流获取温度作为map值,我得到的是温度列表。我的groupingBy实现如下Map>result=this.getTemperatures().stream().collect(Collectors.g