Author: pderop
Date: Thu Jan 28 23:44:46 2016
New Revision: 1727459
URL: http://svn.apache.org/viewvc?rev=1727459&view=rev
Log:
Finalized the sample based on CompletableFuture.
Modified:
felix/sandbox/pderop/dependencymanager-lambda/org.apache.felix.dependencymanager.lambda.samples/src/org/apache/felix/dependencymanager/lambda/samples/future/PageLinksImpl.java
Modified:
felix/sandbox/pderop/dependencymanager-lambda/org.apache.felix.dependencymanager.lambda.samples/src/org/apache/felix/dependencymanager/lambda/samples/future/PageLinksImpl.java
URL:
http://svn.apache.org/viewvc/felix/sandbox/pderop/dependencymanager-lambda/org.apache.felix.dependencymanager.lambda.samples/src/org/apache/felix/dependencymanager/lambda/samples/future/PageLinksImpl.java?rev=1727459&r1=1727458&r2=1727459&view=diff
==============================================================================
---
felix/sandbox/pderop/dependencymanager-lambda/org.apache.felix.dependencymanager.lambda.samples/src/org/apache/felix/dependencymanager/lambda/samples/future/PageLinksImpl.java
(original)
+++
felix/sandbox/pderop/dependencymanager-lambda/org.apache.felix.dependencymanager.lambda.samples/src/org/apache/felix/dependencymanager/lambda/samples/future/PageLinksImpl.java
Thu Jan 28 23:44:46 2016
@@ -1,5 +1,7 @@
package org.apache.felix.dependencymanager.lambda.samples.future;
+import static org.apache.felix.dm.lambda.DependencyActivatorBase.component;
+
import java.io.IOException;
import java.net.URL;
import java.util.ArrayList;
@@ -11,7 +13,6 @@ import java.util.regex.Pattern;
import org.apache.felix.dm.Component;
import org.osgi.service.log.LogService;
-import static org.apache.felix.dm.lambda.DependencyActivatorBase.*;
/**
* Provides all hrefs found from a given web page.
@@ -36,7 +37,7 @@ public class PageLinksImpl implements Pa
.thenApply(PageLinksImpl::parseLinks);
// Add the future dependency so we'll be started once the
CompletableFuture "futureLinks" has completed.
- component(c, comp -> comp.withFuture(futureLinks, links ->
links.cb(PageLinksImpl::setLinks)));
+ component(c, comp -> comp.withFuture(futureLinks, links ->
links.cbi(this::setLinks)));
}
// Called when our future has completed.
