> logger.debug(">> rebooting nodes matching(%s)", filter);
> -
> transformParallel(nodesMatchingFilterAndNotTerminatedExceptionIfNotFound(filter),
> - new Function<NodeMetadata, ListenableFuture<? extends Void>>() {
> - // TODO use native async
> - @Override
> - public ListenableFuture<Void> apply(NodeMetadata from) {
> - rebootNode(from.getId());
> - return immediateFuture(null);
> - }
> -
> - }, userExecutor, null, logger, "rebootNodesMatching(" + filter +
> ")");
> + Set<NodeMetadata> set =
> ImmutableSet.copyOf(transformParallel(nodesMatchingFilterAndNotTerminatedExceptionIfNotFound(filter),
Rename the set to `rebootedNodes` or so?
---
Reply to this email directly or view it on GitHub:
https://github.com/jclouds/jclouds/pull/419/files#r14141322
