You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@aries.apache.org by cs...@apache.org on 2017/09/29 13:20:03 UTC
svn commit: r1810092 -
/aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/JustOSGiImpl.java
Author: csierra
Date: Fri Sep 29 13:20:03 2017
New Revision: 1810092
URL: http://svn.apache.org/viewvc?rev=1810092&view=rev
Log:
[Component-DSL] Source cleaning
Modified:
aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/JustOSGiImpl.java
Modified: aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/JustOSGiImpl.java
URL: http://svn.apache.org/viewvc/aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/JustOSGiImpl.java?rev=1810092&r1=1810091&r2=1810092&view=diff
==============================================================================
--- aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/JustOSGiImpl.java (original)
+++ aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/JustOSGiImpl.java Fri Sep 29 13:20:03 2017
@@ -102,51 +102,4 @@ public class JustOSGiImpl<T> extends OSG
});
}
-/*
- @Override
- public <S> OSGi<S> applyTo(OSGi<Function<T, S>> fun) {
- return new OSGiImpl<>(bundleContext -> {
- Pipe<Tuple<S>, Tuple<S>> added = Pipe.create();
-
- Consumer<Tuple<S>> addedSource = added.getSource();
-
- Pipe<Tuple<S>, Tuple<S>> removed = Pipe.create();
-
- Consumer<Tuple<S>> removedSource = removed.getSource();
-
- IdentityHashMap<Function<T, S>, Tuple<S>> identityMap =
- new IdentityHashMap<>();
-
- OSGi<Void> next = fun.foreach(
- f -> {
- Tuple<S> tuple = Tuple.create(f.apply(_t));
-
- identityMap.put(f, tuple);
-
- addedSource.accept(tuple);
- },
- f -> {
- Tuple<S> tuple = identityMap.remove(f);
-
- if (tuple != null) {
- removedSource.accept(tuple);
- }
- });
-
- AtomicReference<OSGiResult<Void>> atomicReference =
- new AtomicReference<>();
-
- return new OSGiResultImpl<>(
- added, removed,
- () -> atomicReference.set(next.run(bundleContext)),
- () -> {
- identityMap.forEach((f, t) -> removedSource.accept(t));
-
- identityMap.clear();
-
- atomicReference.get().close();
- });
- });
- }
-*/
}