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 2018/06/18 09:34:10 UTC
svn commit: r1833694 -
/aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/component/dsl/OSGi.java
Author: csierra
Date: Mon Jun 18 09:34:10 2018
New Revision: 1833694
URL: http://svn.apache.org/viewvc?rev=1833694&view=rev
Log:
[ARIES-1812] Add update support to once
Modified:
aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/component/dsl/OSGi.java
Modified: aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/component/dsl/OSGi.java
URL: http://svn.apache.org/viewvc/aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/component/dsl/OSGi.java?rev=1833694&r1=1833693&r2=1833694&view=diff
==============================================================================
--- aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/component/dsl/OSGi.java (original)
+++ aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/component/dsl/OSGi.java Mon Jun 18 09:34:10 2018
@@ -59,6 +59,7 @@ import org.apache.aries.component.dsl.in
import org.apache.aries.component.dsl.internal.IgnoreImpl;
import org.apache.aries.component.dsl.internal.JustOSGiImpl;
import org.apache.aries.component.dsl.internal.OSGiImpl;
+import org.apache.aries.component.dsl.internal.UpdateSupport;
import org.osgi.framework.Bundle;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceFactory;
@@ -281,13 +282,13 @@ public interface OSGi<T> extends OSGiRun
terminator.set(op.apply(t));
}
- return () -> {
+ return () -> UpdateSupport.defer(() -> {
if (count.decrementAndGet() == 0) {
Runnable runnable = terminator.getAndSet(NOOP);
runnable.run();
}
- };
+ });
};
});
}