本文整理了Java中io.vavr.collection.List.toJavaList()
方法的一些代码示例,展示了List.toJavaList()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。List.toJavaList()
方法的具体详情如下:
包路径:io.vavr.collection.List
类名称: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)));
内容来源于网络,如有侵权,请联系作者删除!