io.vavr.collection.List.map()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(9.3k)|赞(0)|评价(0)|浏览(148)

本文整理了Java中io.vavr.collection.List.map()方法的一些代码示例,展示了List.map()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。List.map()方法的具体详情如下:
包路径:io.vavr.collection.List
类名称:List
方法名:map

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))
      );
    }
  }
}

相关文章