- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 250 for notifiers (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/union_content.go
panic(err) } return ret.verifyOptions, true } // AddListener adds a listener to be notified when the CA content changes. func (c unionCAContent) AddListener(listener Listener) { for _, curr := range c { curr.AddListener(listener) } } // AddListener adds a listener to be notified when the CA content changes. func (c unionCAContent) RunOnce(ctx context.Context) error { errors := []error{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 07 14:37:01 UTC 2022 - 3.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper.go
InnerCloseNotifierFlusher CloseNotifierFlusher } func (wr outerWithCloseNotifyAndFlush) CloseNotify() <-chan bool { if notifier, ok := wr.UserProvidedDecorator.(http.CloseNotifier); ok { return notifier.CloseNotify() } return wr.InnerCloseNotifierFlusher.CloseNotify() } func (wr outerWithCloseNotifyAndFlush) Flush() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 7K bytes - Viewed (0) -
platforms/core-execution/execution/src/test/groovy/org/gradle/internal/execution/steps/BroadcastChangingOutputsStepTest.groovy
def outputChangeListener = Mock(OutputChangeListener) def delegateResult = Stub(Result) def step = new BroadcastChangingOutputsStep<>(outputChangeListener, delegate) def "notifies listener about specific outputs changing"() { def outputDir = file("output-dir") def localStateDir = file("local-state-dir") def destroyableDir = file("destroyable-dir") def changingOutputs = [
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 22 09:41:23 UTC 2023 - 2.2K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/internal/tasks/execution/EventFiringTaskExecuterTest.groovy
def state = new TaskStateInternal() def executionContext = Mock(TaskExecutionContext) def executer = new EventFiringTaskExecuter(buildOperationRunner, taskExecutionListener, taskListener, delegate) def "notifies task listeners"() { when: executer.execute(task, state, executionContext) then: _ * task.getIdentityPath() >> Path.path(":a") 1 * task.getTaskIdentity() >> taskIdentity
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 6.3K bytes - Viewed (0) -
guava/src/com/google/common/cache/RemovalListener.java
* Object} if any key is acceptable * @author Charles Fry * @since 10.0 */ @GwtCompatible @FunctionalInterface @ElementTypesAreNonnullByDefault public interface RemovalListener<K, V> { /** * Notifies the listener that a removal occurred at some point in the past. * * <p>This does not always signify that the key is now absent from the cache, as it may have * already been re-added. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 2K bytes - Viewed (0) -
platforms/core-runtime/build-option/src/test/groovy/org/gradle/internal/buildoption/DefaultFeatureFlagsTest.groovy
flag.systemPropertyName >> "prop" flags.enable(flag) expect: !flags.isEnabled(flag) flags.isEnabledWithApi(flag) } def "querying flag status notifies listener"() { def flag = Stub(FeatureFlag) flag.systemPropertyName >> propertyName when: flags.isEnabled(flag) then: 1 * featureFlagListener.flagRead(flag)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:02:02 UTC 2023 - 2.9K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/AsyncConsumerActionExecutor.java
/** * Implementations must be thread-safe. */ public interface AsyncConsumerActionExecutor { /** * Runs some operation asynchronously against a consumer connection. Notifies the provided handler when * complete. Note that the action may have completed by the time this method returns. * * @throws IllegalStateException When this connection has been stopped or is stopping. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 1.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/async/DefaultAsyncConsumerActionExecutorTest.groovy
} 1 * handler.onComplete("result") >> { instant.resultReceived } and: instant.actionStarted < instant.resultReceived } def "notifies handler on failure"() { def failure = new RuntimeException() when: async { connection.run(action, handler) } then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 2.4K bytes - Viewed (0) -
platforms/software/build-init/src/main/java/org/gradle/buildinit/plugins/internal/ProjectLayoutSetupRegistry.java
* limitations under the License. */ package org.gradle.buildinit.plugins.internal; import org.gradle.api.GradleException; import org.gradle.buildinit.plugins.internal.modifiers.ComponentType; import org.gradle.buildinit.plugins.internal.modifiers.Language; import org.gradle.internal.logging.text.TreeFormatter; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.Map;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jan 24 20:06:28 UTC 2024 - 5.2K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/configuration/project/LifecycleProjectEvaluatorTest.groovy
and: operations.size() == 3 assertConfigureOp(operations[0]) assertBeforeEvaluateOp(operations[1]) assertAfterEvaluateOp(operations[2]) } void "notifies listeners and updates state on evaluation failure"() { when: 1 * delegate.evaluate(project, state) >> { throw failure1 } 1 * listener.afterEvaluate(project, state) then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 8.9K bytes - Viewed (0)