private void notifyCoreClosedListeners(Throwable th) { synchronized(coreClosedListeners) { for (CoreClosedListener listener : coreClosedListeners) { // SegmentReader uses our instance as its // coreCacheKey: try { listener.onClose(this); } catch (Throwable t) { if (th == null) { th = t; } } } IOUtils.reThrowUnchecked(th); } }
private void notifyCoreClosedListeners() { synchronized(coreClosedListeners) { for (CoreClosedListener listener : coreClosedListeners) { listener.onClose(owner); } } }
private void notifyCoreClosedListeners() { synchronized(coreClosedListeners) { for (CoreClosedListener listener : coreClosedListeners) { // SegmentReader uses our instance as its // coreCacheKey: listener.onClose(this); } } }
void addCoreClosedListener(CoreClosedListener listener) { coreClosedListeners.add(listener); }
void removeCoreClosedListener(CoreClosedListener listener) { coreClosedListeners.remove(listener); }