in jax-rs.whiteboard/src/main/java/org/apache/aries/jax/rs/whiteboard/internal/ServiceReferenceFilteredPublisher.java [49:73]
public void publishIfMatched(CachingServiceReference<?> serviceReference) {
if (_closed.get()) {
return;
}
if (_filter.match(serviceReference.getServiceReference())) {
OSGiResult result = _publisher.publish(serviceReference);
_results.compute(
serviceReference,
(__, results) -> {
if (results == null) {
results = new ArrayList<>();
}
results.add(result);
return results;
});
if (_closed.get()) {
result.close();
}
}
}