- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for hasListeners (0.31 sec)
-
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
private final ExecutionList executionList = new ExecutionList(); // This allows us to only start up a thread waiting on the delegate future when the first // listener is added. private final AtomicBoolean hasListeners = new AtomicBoolean(false); // The delegate future. private final Future<V> delegate; ListenableFutureAdapter(Future<V> delegate) { this(delegate, defaultAdapterExecutor); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 7.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/event/DefaultListenerManagerTest.groovy
expect: !manager.hasListeners(TestFooListener) when: manager.getBroadcaster(TestFooListener) then: !manager.hasListeners(TestFooListener) when: manager.addListener(fooListener1) then: manager.hasListeners(TestFooListener) !manager.hasListeners(TestBarListener) when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 29.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
private final ExecutionList executionList = new ExecutionList(); // This allows us to only start up a thread waiting on the delegate future when the first // listener is added. private final AtomicBoolean hasListeners = new AtomicBoolean(false); // The delegate future. private final Future<V> delegate; ListenableFutureAdapter(Future<V> delegate) { this(delegate, defaultAdapterExecutor); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 7.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/tasks/execution/TaskExecution.java
} } private void executeActions(TaskInternal task, @Nullable InputChangesInternal inputChanges) { boolean hasTaskListener = listenerManager.hasListeners(org.gradle.api.execution.TaskActionListener.class) || listenerManager.hasListeners(org.gradle.api.execution.TaskExecutionListener.class); Iterator<InputChangesAwareTaskAction> actions = new ArrayList<>(task.getTaskActions()).iterator();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 23.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/ListenerManager.java
* * @param listenerClass The type of listener to check. * @return True if a listener of the specified type is currently registered, false otherwise. */ <T> boolean hasListeners(Class<T> listenerClass); /** * Returns a broadcaster for the given listenerClass. Any method invoked on the broadcaster is forwarded to all registered
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 5.6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/DefaultListenerManager.java
allLoggers.put(logger, details); } } if (details != null) { details.useAsLogger(); } } @Override public <T> boolean hasListeners(Class<T> listenerClass) { EventBroadcast<T> broadcaster = getBroadcasterInternal(listenerClass); return !broadcaster.listeners.isEmpty(); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 10:09:43 UTC 2024 - 18.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
abstract boolean casListeners( AbstractFuture<?> future, @CheckForNull Listener expect, Listener update); /** Performs a GAS operation on the {@link #waiters} field. */ abstract Waiter gasWaiters(AbstractFuture<?> future, Waiter update); /** Performs a GAS operation on the {@link #listeners} field. */ abstract Listener gasListeners(AbstractFuture<?> future, Listener update);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
abstract boolean casListeners( AbstractFuture<?> future, @CheckForNull Listener expect, Listener update); /** Performs a GAS operation on the {@link #waiters} field. */ abstract Waiter gasWaiters(AbstractFuture<?> future, Waiter update); /** Performs a GAS operation on the {@link #listeners} field. */ abstract Listener gasListeners(AbstractFuture<?> future, Listener update);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1) -
samples/bookinfo/src/productpage/static/tailwind/tailwind.css
s.error)throw this.error;if(this.processed)return this.result;if(this.processed=!0,this.processing)throw this.getAsyncError();for(let e of this.plugins){let t=this.runOnRoot(e);if(Sr(t))throw this.getAsyncError()}if(this.prepareVisitors(),this.hasListener){let e=this.result.root;for(;!e[qe];)e[qe]=!0,this.walkSync(e);if(this.listeners.OnceExit)if(e.type==="document")for(let t of e.nodes)this.visitSync(this.listeners.OnceExit,t);else this.visitSync(this.listeners.OnceExit,e)}return this.result}st...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 14:48:01 UTC 2024 - 357.1K bytes - Viewed (1) -
src/internal/trace/traceviewer/static/trace_viewer_full.html
if(!this._hasListeners()){this._cleanup();this._isSetup=false;}},_setup:function(){this._observeContentElements(this.domApi.childNodes);},_cleanup:function(){this._unobserveContentElements(this.domApi.childNodes);},_hasListeners:function(){return Boolean(this._liste...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 20:45:06 UTC 2023 - 2.5M bytes - Viewed (0)