本文整理了Java中cyclops.reactive.ReactiveSeq.toMap
方法的一些代码示例,展示了ReactiveSeq.toMap
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ReactiveSeq.toMap
方法的具体详情如下:
包路径:cyclops.reactive.ReactiveSeq
类名称:ReactiveSeq
方法名:toMap
暂无
代码示例来源:origin: aol/micro-server
public static Optional<RegisterEntry> toRegisterEntry(UriInfo uriInfo) {
if (uriInfo.getQueryParameters().isEmpty()) {
return Optional.empty();
} else {
MultivaluedMap<String, String> parameters = uriInfo.getQueryParameters();
RegisterEntry re = RegisterEntry.builder()
.context(parameters.getFirst("context"))
.hostname(parameters.getFirst("hostname"))
.port(toInt(parameters.getFirst("port")))
.target(parameters.getFirst("target"))
.externalPort(toInt(parameters.getFirst("externalPort")))
.module(parameters.getFirst("module"))
.health(toHealth(parameters.getFirst("health")))
.build();
Map<String, String> manifest = ReactiveSeq.fromIterable(parameters.entrySet())
.filter(e -> e.getKey().startsWith("manifest."))
.toMap(e -> e.getKey().replace("manifest.", ""),
e -> parameters.getFirst(e.getKey()));
re.getManifest().clear();
re.getManifest().putAll(manifest);
return Optional.of(re);
}
}
代码示例来源:origin: aol/micro-server
private Map<String, String> buildProperties(Microserver microserver) {
Map<String, String> properties = ReactiveSeq.of(microserver.properties())
.grouped(2)
.toMap(prop -> prop.getOrElse(0,null), prop -> prop.getOrElse(1,null));
return properties;
}
代码示例来源:origin: com.oath.microservices/micro-application-register
public static Optional<RegisterEntry> toRegisterEntry(UriInfo uriInfo) {
if (uriInfo.getQueryParameters().isEmpty()) {
return Optional.empty();
} else {
MultivaluedMap<String, String> parameters = uriInfo.getQueryParameters();
RegisterEntry re = RegisterEntry.builder()
.context(parameters.getFirst("context"))
.hostname(parameters.getFirst("hostname"))
.port(toInt(parameters.getFirst("port")))
.target(parameters.getFirst("target"))
.externalPort(toInt(parameters.getFirst("externalPort")))
.module(parameters.getFirst("module"))
.health(toHealth(parameters.getFirst("health")))
.build();
Map<String, String> manifest = ReactiveSeq.fromIterable(parameters.entrySet())
.filter(e -> e.getKey().startsWith("manifest."))
.toMap(e -> e.getKey().replace("manifest.", ""),
e -> parameters.getFirst(e.getKey()));
re.getManifest().clear();
re.getManifest().putAll(manifest);
return Optional.of(re);
}
}
代码示例来源:origin: com.oath.microservices/micro-core
private Map<String, String> buildProperties(Microserver microserver) {
Map<String, String> properties = ReactiveSeq.of(microserver.properties())
.grouped(2)
.toMap(prop -> prop.getOrElse(0,null), prop -> prop.getOrElse(1,null));
return properties;
}
内容来源于网络,如有侵权,请联系作者删除!