Do not return impl type
git-svn-id: https://svn.apache.org/repos/asf/aries/trunk@1828200 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/OSGiImpl.java b/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/OSGiImpl.java
index 382d049..4dddc04 100644
--- a/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/OSGiImpl.java
+++ b/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/OSGiImpl.java
@@ -207,7 +207,7 @@
}
@Override
- public <S> OSGiImpl<S> flatMap(Function<? super T, OSGi<? extends S>> fun) {
+ public <S> OSGi<S> flatMap(Function<? super T, OSGi<? extends S>> fun) {
return new OSGiImpl<>((bundleContext, op) ->
run(
bundleContext,
diff --git a/itests/src/main/java/org/apache/aries/osgi/functional/internal/ProbeTests.java b/itests/src/main/java/org/apache/aries/osgi/functional/internal/ProbeTests.java
index b64beee..34d169c 100644
--- a/itests/src/main/java/org/apache/aries/osgi/functional/internal/ProbeTests.java
+++ b/itests/src/main/java/org/apache/aries/osgi/functional/internal/ProbeTests.java
@@ -50,7 +50,7 @@
ProbeImpl<String> probeA = new ProbeImpl<>();
AtomicReference<ProbeImpl<String>> probeBreference = new AtomicReference<>();
- OSGiImpl<String> program =
+ OSGi<String> program =
probeA.flatMap(a ->
onClose(
() -> result.accumulateAndGet("Hello", (x, y) -> x.replace(y, ""))).
