Bha*_*gat 2 lambda java-8 java-stream
我想对任何不成功的响应都有failfast行为,如果一切都成功,那么我将返回上一个成功的响应,如下面的代码所示.
for(int i=0;i<input.size(); i++){
Data data = service.getData(input.get(i));
if(data.isSuccessful() && i==input.size()-1){
return data;
}else if(!data.isSuccessful()){
return data;
}else{
return null;
}
}
Run Code Online (Sandbox Code Playgroud)
我试图用流替换上面提到的代码,但是到目前为止还没能做到.主要问题是我无法模仿java8流代码中的i(索引)变量行为.
resp = input.stream().map((input)->{service.getData()}).filter(
(resp)->{
if(!resp.isSuccessful())
return true;
else if(resp.isSuccessful() && last resp)//if somehow I figure out last element
return true;
else
return false;}).findFirst();
Run Code Online (Sandbox Code Playgroud)
不需要外部库.
return IntStream.range(0, input.size())
.mapToObj(i -> {
Data data = service.getData(input.get(i));
if (!data.isSuccessful() || i == input.size() - 1) {
return Optional.of(data);
}
return Optional.<Data>empty();
})
.filter(Optional::isPresent)
.findFirst()
.orElse(null);
Run Code Online (Sandbox Code Playgroud)
Optional
,而不是结果或null
完整示例(可编译):
import java.util.Optional;
import java.util.stream.IntStream;
class Data {
public boolean isSuccessful() {return false;}
}
class Input {
public Object get(int i) {return null;}
public int size() {return 0;}
}
class Service {
public Data getData(Object object) {return null;}
}
public class T {
public static void main(String[] args) {method();}
protected static Optional<Data> method() {
Input input = new Input();
Service service = new Service();
return IntStream.range(0, input.size())
.mapToObj(i -> {
Data data = service.getData(input.get(i));
if (!data.isSuccessful() || i == input.size() - 1) {
return Optional.of(data);
}
return Optional.<Data>empty();
})
.filter(Optional::isPresent)
.findFirst()
.orElse(null);
}
}
Run Code Online (Sandbox Code Playgroud)
归档时间: |
|
查看次数: |
2178 次 |
最近记录: |