Lambda的方法参考



在我们使用lambda表达式的一种方法中(下)嵌套流。

return req.gUs().stream()
.map((**cfg) -> {
.filter(Optional::isPresent)
.map(Optional::get);

我想使用一些辅助方法和方法参考移动代码的一部分(下)。

(cfg) -> {
return rsp.getUs().stream()
.filter(result.getId())    
.map((result) -> gEvent(index, Builder, cfg));

任何建议都非常感谢。

您可以制作一个返回函数的方法:

return req.getUs().stream()
.map(myFunction(rsp, index, headerBuilder))
.flatMap(stream -> stream)
.filter(Optional::isPresent)
.map(Optional::get);
private Function<CFGType, GenerateReturnType> myFunction(RspType rsp, IndexType index, HeaderType header){
  return (cfg) -> {
    return rsp.getPerUs().stream()
    .filter((result) -> cfg.getId() == result.getId())
    .filter((result) -> result.getCode() == ResultCode.SUCCESS)
    .map((result) -> generateEvent(index, headerBuilder, cfg));
  }
}

,如果RSP,索引和标头是字段:

,则可以使用方法参考
return req.getUs().stream()
.map(this::myFunction)
.flatMap(stream -> stream)
.filter(Optional::isPresent)
.map(Optional::get);
private GenerateType myFunction(CFGType cfg) {
  return rsp.getUs().stream()
  .filter((result) -> cfg.getUsChId() == result.getChId())
  .filter((result) -> result.getResultCode() == ResultCode.SUCCESS)
  .map((result) -> generateEvent(index, headerBuilder, cfg));
}

最新更新