in component-dsl/src/main/java/org/apache/aries/component/dsl/internal/OSGiImpl.java [50:65]
public OSGiResult run(
ExecutionContext ec, Publisher<? super T> op) {
return operation.run(ec,
op.pipe(t -> {
try {
return op.publish(t);
} catch (PublisherRethrowException pre) {
rethrow(pre.getCause());
return null;
} catch (Exception e) {
return op.error(t, e);
}
}));
}