本文整理了Java中io.vavr.collection.List.map()
方法的一些代码示例,展示了List.map()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。List.map()
方法的具体详情如下:
包路径:io.vavr.collection.List
类名称:List
方法名:map
暂无
代码示例来源:origin: vavr-io/vavr
/**
* Yields a result for elements of the cross product of the underlying List.
*
* @param f a function that maps an element of the cross product to a result
* @param <R> type of the resulting {@code List} elements
* @return an {@code List} of mapped results
*/
public <R> List<R> yield(Function<? super T1, ? extends R> f) {
Objects.requireNonNull(f, "f is null");
return ts1.map(f);
}
代码示例来源:origin: vavr-io/vavr
@Override
public <U> Queue<U> map(Function<? super T, ? extends U> mapper) {
Objects.requireNonNull(mapper, "mapper is null");
return new Queue<>(front.map(mapper), rear.map(mapper));
}
代码示例来源:origin: vavr-io/vavr
/**
* Yields a result for elements of the cross product of the underlying Lists.
*
* @param f a function that maps an element of the cross product to a result
* @param <R> type of the resulting {@code List} elements
* @return an {@code List} of mapped results
*/
public <R> List<R> yield(BiFunction<? super T1, ? super T2, ? extends R> f) {
Objects.requireNonNull(f, "f is null");
return
ts1.flatMap(t1 ->
ts2.map(t2 -> f.apply(t1, t2)));
}
代码示例来源:origin: vavr-io/vavr
static <T, T1, T2, T3> Tuple3<Node<T1>, Node<T2>, Node<T3>> unzip3(Node<T> node,
Function<? super T, Tuple3<? extends T1, ? extends T2, ? extends T3>> unzipper) {
final Tuple3<? extends T1, ? extends T2, ? extends T3> value = unzipper.apply(node.getValue());
final io.vavr.collection.List<Tuple3<Node<T1>, Node<T2>, Node<T3>>> children = node.getChildren()
.map(child -> unzip3(child, unzipper));
final Node<T1> node1 = new Node<>(value._1, children.map(t -> t._1));
final Node<T2> node2 = new Node<>(value._2, children.map(t -> t._2));
final Node<T3> node3 = new Node<>(value._3, children.map(t -> t._3));
return Tuple.of(node1, node2, node3);
}
代码示例来源:origin: vavr-io/vavr
static <T, T1, T2> Tuple2<Node<T1>, Node<T2>> unzip(Node<T> node,
Function<? super T, Tuple2<? extends T1, ? extends T2>> unzipper) {
final Tuple2<? extends T1, ? extends T2> value = unzipper.apply(node.getValue());
final io.vavr.collection.List<Tuple2<Node<T1>, Node<T2>>> children = node
.getChildren()
.map(child -> unzip(child, unzipper));
final Node<T1> node1 = new Node<>(value._1, children.map(t -> t._1));
final Node<T2> node2 = new Node<>(value._2, children.map(t -> t._2));
return Tuple.of(node1, node2);
}
代码示例来源:origin: vavr-io/vavr
@Override
default List<List<T>> combinations() {
return rangeClosed(0, length()).map(this::combinations).flatMap(Function.identity());
}
代码示例来源:origin: resilience4j/resilience4j
@RequestMapping(value = "events/{circuitBreakerName}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
@ResponseBody
public CircuitBreakerEventsEndpointResponse getEventsFilteredByCircuitBreakerName(@PathVariable("circuitBreakerName") String circuitBreakerName) {
return new CircuitBreakerEventsEndpointResponse(eventConsumerRegistry.getEventConsumer(circuitBreakerName).getBufferedEvents()
.filter(event -> event.getCircuitBreakerName().equals(circuitBreakerName))
.map(CircuitBreakerEventDTOFactory::createCircuitBreakerEventDTO).toJavaList());
}
代码示例来源:origin: resilience4j/resilience4j
@RequestMapping(value = "events/{rateLimiterName}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
@ResponseBody
public RateLimiterEventsEndpointResponse getEventsFilteredByRateLimiterName(@PathVariable("rateLimiterName") String rateLimiterName) {
List<RateLimiterEventDTO> eventsList = eventsConsumerRegistry.getEventConsumer(rateLimiterName).getBufferedEvents()
.filter(event -> event.getRateLimiterName().equals(rateLimiterName))
.map(RateLimiterEventDTO::createRateLimiterEventDTO).toJavaList();
return new RateLimiterEventsEndpointResponse(eventsList);
}
代码示例来源:origin: vavr-io/vavr
static <T, U> Node<U> map(Node<T> node, Function<? super T, ? extends U> mapper) {
final U value = mapper.apply(node.getValue());
final io.vavr.collection.List<Node<U>> children = node.getChildren().map(child -> map(child, mapper));
return new Node<>(value, children);
}
代码示例来源:origin: resilience4j/resilience4j
@RequestMapping(value = "events/{circuitBreakerName}/{eventType}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
@ResponseBody
public CircuitBreakerEventsEndpointResponse getEventsFilteredByCircuitBreakerNameAndEventType(@PathVariable("circuitBreakerName") String circuitBreakerName,
@PathVariable("eventType") String eventType) {
return new CircuitBreakerEventsEndpointResponse(eventConsumerRegistry.getEventConsumer(circuitBreakerName).getBufferedEvents()
.filter(event -> event.getCircuitBreakerName().equals(circuitBreakerName))
.filter(event -> event.getEventType() == CircuitBreakerEvent.Type.valueOf(eventType.toUpperCase()))
.map(CircuitBreakerEventDTOFactory::createCircuitBreakerEventDTO).toJavaList());
}
代码示例来源:origin: resilience4j/resilience4j
@RequestMapping(value = "events/{rateLimiterName}/{eventType}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
@ResponseBody
public RateLimiterEventsEndpointResponse getEventsFilteredByRateLimiterNameAndEventType(@PathVariable("rateLimiterName") String rateLimiterName,
@PathVariable("eventType") String eventType) {
RateLimiterEvent.Type targetType = RateLimiterEvent.Type.valueOf(eventType.toUpperCase());
List<RateLimiterEventDTO> eventsList = eventsConsumerRegistry.getEventConsumer(rateLimiterName).getBufferedEvents()
.filter(event -> event.getRateLimiterName().equals(rateLimiterName))
.filter(event -> event.getEventType() == targetType)
.map(RateLimiterEventDTO::createRateLimiterEventDTO).toJavaList();
return new RateLimiterEventsEndpointResponse(eventsList);
}
代码示例来源:origin: vavr-io/vavr
@Override
public Queue<Queue<T>> permutations() {
return ofAll(toList().permutations().map(io.vavr.collection.List::toQueue));
}
代码示例来源:origin: vavr-io/vavr
@Override
public Queue<Queue<T>> combinations() {
return ofAll(toList().combinations().map(Queue::ofAll));
}
代码示例来源:origin: vavr-io/vavr
@SuppressWarnings("unchecked")
static <T, U, R> Tree<R> zip(Node<T> node, java.util.Iterator<? extends U> that, BiFunction<? super T, ? super U, ? extends R> mapper) {
if (!that.hasNext()) {
return Empty.instance();
} else {
final R value = mapper.apply(node.getValue(), that.next());
final io.vavr.collection.List<Node<R>> children = (io.vavr.collection.List<Node<R>>) (Object) node
.getChildren()
.map(child -> zip(child, that, mapper))
.filter(Tree::nonEmpty);
return new Node<>(value, children);
}
}
代码示例来源:origin: vavr-io/vavr
private static String toLispString(Tree<?> tree) {
final String value = String.valueOf(tree.getValue());
if (tree.isLeaf()) {
return value;
} else {
final String children = tree.getChildren().map(child -> toLispString(child)).mkString(" ");
return "(" + value + " " + children + ")";
}
}
代码示例来源:origin: resilience4j/resilience4j
@ReadOperation
public CircuitBreakerEventsEndpointResponse getEventsFilteredByCircuitBreakerName(@Selector String name) {
return new CircuitBreakerEventsEndpointResponse(eventConsumerRegistry.getEventConsumer(name).getBufferedEvents()
.filter(event -> event.getCircuitBreakerName().equals(name))
.map(CircuitBreakerEventDTOFactory::createCircuitBreakerEventDTO).toJavaList());
}
代码示例来源:origin: resilience4j/resilience4j
@ReadOperation
public RateLimiterEventsEndpointResponse getEventsFilteredByRateLimiterName(@Selector String name) {
List<RateLimiterEventDTO> eventsList = eventsConsumerRegistry.getEventConsumer(name).getBufferedEvents()
.filter(event -> event.getRateLimiterName().equals(name))
.map(RateLimiterEventDTO::createRateLimiterEventDTO).toJavaList();
return new RateLimiterEventsEndpointResponse(eventsList);
}
代码示例来源:origin: resilience4j/resilience4j
@ReadOperation
public RateLimiterEventsEndpointResponse getEventsFilteredByRateLimiterNameAndEventType(@Selector String name,
@Selector String eventType) {
RateLimiterEvent.Type targetType = RateLimiterEvent.Type.valueOf(eventType.toUpperCase());
List<RateLimiterEventDTO> eventsList = eventsConsumerRegistry.getEventConsumer(name).getBufferedEvents()
.filter(event -> event.getRateLimiterName().equals(name))
.filter(event -> event.getEventType() == targetType)
.map(RateLimiterEventDTO::createRateLimiterEventDTO).toJavaList();
return new RateLimiterEventsEndpointResponse(eventsList);
}
}
代码示例来源:origin: resilience4j/resilience4j
@ReadOperation
public CircuitBreakerEventsEndpointResponse getEventsFilteredByCircuitBreakerNameAndEventType(@Selector String name, @Selector String eventType) {
return new CircuitBreakerEventsEndpointResponse(eventConsumerRegistry.getEventConsumer(name).getBufferedEvents()
.filter(event -> event.getCircuitBreakerName().equals(name))
.filter(event -> event.getEventType() == CircuitBreakerEvent.Type.valueOf(eventType.toUpperCase()))
.map(CircuitBreakerEventDTOFactory::createCircuitBreakerEventDTO).toJavaList());
}
}
代码示例来源:origin: vavr-io/vavr
static <T> List<List<T>> apply(List<T> elements, int k) {
if (k == 0) {
return List.of(List.empty());
} else {
return elements.zipWithIndex().flatMap(
t -> apply(elements.drop(t._2 + 1), (k - 1)).map(c -> c.prepend(t._1))
);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!