Use effects primitive

Project: http://git-wip-us.apache.org/repos/asf/aries-jax-rs-whiteboard/repo
Commit: 
http://git-wip-us.apache.org/repos/asf/aries-jax-rs-whiteboard/commit/43acc44f
Tree: 
http://git-wip-us.apache.org/repos/asf/aries-jax-rs-whiteboard/tree/43acc44f
Diff: 
http://git-wip-us.apache.org/repos/asf/aries-jax-rs-whiteboard/diff/43acc44f

Branch: refs/heads/master
Commit: 43acc44f019e03419ad217baaef358c159b3d5d7
Parents: ede757b
Author: Carlos Sierra <[email protected]>
Authored: Wed Nov 29 11:19:39 2017 +0100
Committer: Carlos Sierra <[email protected]>
Committed: Wed Nov 29 11:22:01 2017 +0100

----------------------------------------------------------------------
 .../org/apache/aries/jax/rs/whiteboard/internal/Whiteboard.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/aries-jax-rs-whiteboard/blob/43acc44f/jax-rs.whiteboard/src/main/java/org/apache/aries/jax/rs/whiteboard/internal/Whiteboard.java
----------------------------------------------------------------------
diff --git 
a/jax-rs.whiteboard/src/main/java/org/apache/aries/jax/rs/whiteboard/internal/Whiteboard.java
 
b/jax-rs.whiteboard/src/main/java/org/apache/aries/jax/rs/whiteboard/internal/Whiteboard.java
index 9eed2be..4426e93 100644
--- 
a/jax-rs.whiteboard/src/main/java/org/apache/aries/jax/rs/whiteboard/internal/Whiteboard.java
+++ 
b/jax-rs.whiteboard/src/main/java/org/apache/aries/jax/rs/whiteboard/internal/Whiteboard.java
@@ -653,10 +653,9 @@ public class Whiteboard {
         }
 
         return
-            just(0).
             effects(
-                __ -> onWaiting.accept(serviceReference),
-                __ -> onResolved.accept(serviceReference)).then(
+                () -> onWaiting.accept(serviceReference),
+                () -> onResolved.accept(serviceReference)).then(
             serviceReferences(
                 CXFJaxRsServiceRegistrator.class,
                 applicationSelectProperty.toString()).

Reply via email to