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

List.filter介绍

暂无

代码示例

代码示例来源：origin: vavr-io/vavr

@Override
default List<T> distinctBy(Comparator<? super T> comparator) {
  Objects.requireNonNull(comparator, "comparator is null");
  final java.util.Set<T> seen = new java.util.TreeSet<>(comparator);
  return filter(seen::add);
}

代码示例来源：origin: vavr-io/vavr

@Override
default <U> List<T> distinctBy(Function<? super T, ? extends U> keyExtractor) {
  Objects.requireNonNull(keyExtractor, "keyExtractor is null");
  final java.util.Set<U> seen = new java.util.HashSet<>();
  return filter(t -> seen.add(keyExtractor.apply(t)));
}

代码示例来源：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: Swagger2Markup/swagger2markup

public Parameters(StringColumn... columns) {
    this.dataFrame = DataFrame.ofAll(List.of(columns).filter(TableComponent::isNotBlank));
  }
}

代码示例来源：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

@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: 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

@Override
public Queue<T> filter(Predicate<? super T> predicate) {
  Objects.requireNonNull(predicate, "predicate is null");
  final io.vavr.collection.List<T> filtered = toList().filter(predicate);
  if (filtered.isEmpty()) {
    return empty();
  } else if (filtered.length() == length()) {
    return this;
  } else {
    return ofAll(filtered);
  }
}

代码示例来源：origin: vavr-io/vavr

@SuppressWarnings("unchecked")
  static <T, U> Tree<Tuple2<T, U>> zipAll(Node<T> node, java.util.Iterator<? extends U> that, U thatElem) {
    if (!that.hasNext()) {
      return node.map(value -> Tuple.of(value, thatElem));
    } else {
      final Tuple2<T, U> value = Tuple.of(node.getValue(), that.next());
      final io.vavr.collection.List<Node<Tuple2<T, U>>> children = (io.vavr.collection.List<Node<Tuple2<T, U>>>) (Object) node
          .getChildren()
          .map(child -> zipAll(child, that, thatElem))
          .filter(Tree::nonEmpty);
      return new Node<>(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: vavr-io/vavr

@SuppressWarnings("unchecked")
static <T, U> Tree<U> flatMap(Node<T> node, Function<? super T, ? extends Iterable<? extends U>> mapper) {
  final Tree<U> mapped = ofAll(mapper.apply(node.getValue()));
  if (mapped.isEmpty()) {
    return empty();
  } else {
    final io.vavr.collection.List<Node<U>> children = (io.vavr.collection.List<Node<U>>) (Object) node
        .getChildren()
        .map(child -> flatMap(child, mapper))
        .filter(Tree::nonEmpty);
    return of(mapped.get(), children.prependAll(mapped.getChildren()));
  }
}

代码示例来源：origin: resilience4j/resilience4j

.getBufferedEvents()
    .sorted(Comparator.comparing(RetryEvent::getCreationTime))
    .filter(event -> event.getEventType() == RetryEvent.Type.valueOf(eventType.toUpperCase()))
    .map(RetryEventDTO::createRetryEventDTO).toJavaList();
d.success(new RetryEventsEndpointResponse(eventsList));

代码示例来源：origin: resilience4j/resilience4j

.getBufferedEvents()
    .sorted(Comparator.comparing(RateLimiterEvent::getCreationTime))
    .filter(event -> event.getEventType() == RateLimiterEvent.Type.valueOf(eventType.toUpperCase()))
    .map(RateLimiterEventDTO::createRateLimiterEventDTO).toJavaList();
d.success(new RateLimiterEventsEndpointResponse(eventsList));

代码示例来源：origin: resilience4j/resilience4j

.getEventConsumer(circuitBreakerName)
    .getBufferedEvents()
    .filter(event -> event.getEventType() == CircuitBreakerEvent.Type.valueOf(eventType.toUpperCase()))
    .map(CircuitBreakerEventDTOFactory::createCircuitBreakerEventDTO).toJavaList());
d.success(response);

代码示例来源：origin: resilience4j/resilience4j

.getEventConsumer(bulkheadName)
    .getBufferedEvents()
    .filter(event -> event.getEventType() == BulkheadEvent.Type.valueOf(eventType.toUpperCase()))
    .map(BulkheadEventDTO::createEventDTO).toJavaList());
d.success(response);

代码示例来源：origin: io.vavr/vavr

@Override
default <U> List<T> distinctBy(Function<? super T, ? extends U> keyExtractor) {
  Objects.requireNonNull(keyExtractor, "keyExtractor is null");
  final java.util.Set<U> seen = new java.util.HashSet<>();
  return filter(t -> seen.add(keyExtractor.apply(t)));
}