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

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

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

List.toJavaList介绍

暂无

代码示例

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

static <T> Stream<Node<T>> traverseLevelOrder(Node<T> node) {
  Stream<Node<T>> result = Stream.empty();
  final java.util.Queue<Node<T>> queue = new java.util.LinkedList<>();
  queue.add(node);
  while (!queue.isEmpty()) {
    final Node<T> next = queue.remove();
    result = result.prepend(next);
    queue.addAll(next.getChildren().toJavaList());
  }
  return result.reverse();
}

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

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

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

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

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

.getEventConsumer(bulkheadName)
      .getBufferedEvents()
      .map(BulkheadEventDTO::createEventDTO).toJavaList());
  d.success(response);
}).then(r -> ctx.render(Jackson.json(r)));
      .getBufferedEvents()
      .filter(event -> event.getEventType() == BulkheadEvent.Type.valueOf(eventType.toUpperCase()))
      .map(BulkheadEventDTO::createEventDTO).toJavaList());
  d.success(response);
}).then(r -> ctx.render(Jackson.json(r)));

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

.getEventConsumer(circuitBreakerName)
      .getBufferedEvents()
      .map(CircuitBreakerEventDTOFactory::createCircuitBreakerEventDTO).toJavaList());
  d.success(response);
}).then(r -> ctx.render(Jackson.json(r)));
      .getBufferedEvents()
      .filter(event -> event.getEventType() == CircuitBreakerEvent.Type.valueOf(eventType.toUpperCase()))
      .map(CircuitBreakerEventDTOFactory::createCircuitBreakerEventDTO).toJavaList());
  d.success(response);
}).then(r -> ctx.render(Jackson.json(r)));

代码示例来源:origin: nikhilnanivadekar/CollectionsCompare

public List<Card> shuffle(Random random)
{
  java.util.List<Card> shuffled = this.cards.toJavaList();
  Collections.shuffle(shuffled, random);
  Collections.shuffle(shuffled, random);
  Collections.shuffle(shuffled, random);
  return List.<Card>empty().pushAll(shuffled);
}

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

static <T> Stream<Node<T>> traverseLevelOrder(Node<T> node) {
  Stream<Node<T>> result = Stream.empty();
  final java.util.Queue<Node<T>> queue = new java.util.LinkedList<>();
  queue.add(node);
  while (!queue.isEmpty()) {
    final Node<T> next = queue.remove();
    result = result.prepend(next);
    queue.addAll(next.getChildren().toJavaList());
  }
  return result.reverse();
}

代码示例来源:origin: com.pragmaticobjects.oo.atom/atom-basis

@Override
  public final StackManipulation stackManipulation() {
    return new StackManipulation.Compound(
      tokens.map(StackManipulationToken::stackManipulation).toJavaList()
    );
  }
}

代码示例来源:origin: com.pragmaticobjects.oo.atom/atom-basis

@Override
  public final StackManipulation stackManipulation() {
    return members.transform(
      list -> ArrayFactory.forType(type.asGenericType()).withValues(
        list.map(StackManipulationToken::stackManipulation).toJavaList()
      )
    );
  }
}

代码示例来源:origin: com.pragmaticobjects.oo.atom/atom-basis

@Override
  public final ClassFileLocatorSource classFileLocatorSource() {
    return new CflsExplicit(
      parts
        .map(ClassFileLocatorSource::classFileLocator)
        .transform(cflsl -> new ClassFileLocator.Compound(cflsl.toJavaList()))
    );
  }
}

代码示例来源:origin: io.github.resilience4j/resilience4j-ratpack

.getEventConsumer(circuitBreakerName)
      .getBufferedEvents()
      .map(CircuitBreakerEventDTOFactory::createCircuitBreakerEventDTO).toJavaList());
  d.success(response);
}).then(r -> ctx.render(Jackson.json(r)));
      .getBufferedEvents()
      .filter(event -> event.getEventType() == CircuitBreakerEvent.Type.valueOf(eventType.toUpperCase()))
      .map(CircuitBreakerEventDTOFactory::createCircuitBreakerEventDTO).toJavaList());
  d.success(response);
}).then(r -> ctx.render(Jackson.json(r)));

代码示例来源:origin: io.github.resilience4j/resilience4j-ratpack

.getEventConsumer(bulkheadName)
      .getBufferedEvents()
      .map(BulkheadEventDTO::createEventDTO).toJavaList());
  d.success(response);
}).then(r -> ctx.render(Jackson.json(r)));
      .getBufferedEvents()
      .filter(event -> event.getEventType() == BulkheadEvent.Type.valueOf(eventType.toUpperCase()))
      .map(BulkheadEventDTO::createEventDTO).toJavaList());
  d.success(response);
}).then(r -> ctx.render(Jackson.json(r)));

相关文章