- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 572 for notified (0.28 sec)
-
platforms/core-configuration/model-core/src/test/groovy/org/gradle/api/internal/provider/DefaultValueSourceProviderFactoryTest.groovy
provider.get() then: "beforeValueObtained callback is notified" 1 * computationListener.beforeValueObtained() then: "afterValueObtained callback is notified" 1 * computationListener.afterValueObtained() then: "valueObtained is notified" obtainedValues.size() == 1 obtainedValues[0].valueSourceType == EchoValueSource
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 08:26:25 UTC 2024 - 10.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubTest.groovy
} thread.blockUntil.notified then: 1 * handler.endStream() >> { thread.blockUntil.signal instant.notified } 0 * _._ } def "notifies handler that the end of incoming messages has been reached when stop requested and end-of-stream reached for all connections"() { BoundedDispatch<String> handler = Mock()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 21.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
t.Error(err) } if handled != 0 { t.Errorf("notified workload handler %d times, want %d", handled, 0) } if err := f(nil, &v1.Pod{ObjectMeta: pod1, Status: v1.PodStatus{Conditions: readyCondition, PodIP: ip, Phase: v1.PodPending}}, model.EventUpdate); err != nil { t.Error(err) } if handled != 1 { t.Errorf("notified workload handler %d times, want %d", handled, 1) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/DefaultListenerManager.java
} private List<Dispatch<MethodInvocation>> startNotification(boolean includeLogger) { takeOwnership(); if (!notified) { maybeAddPendingRegistrations(type); notified = true; } // Take a snapshot while holding lock List<Dispatch<MethodInvocation>> result = includeLogger ? allWithLogger : allWithNoLogger;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 10:09:43 UTC 2024 - 18.3K bytes - Viewed (0) -
.github/actions/notify-translations/app/main.py
already_done_comment: Union[Comment, None] = None logging.info( f"Checking current comments in discussion: #{discussion.number} to see if already notified about this PR: #{pr.number}" ) comments = get_graphql_translation_discussion_comments( settings=settings, discussion_number=discussion.number ) for comment in comments:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Sep 27 23:01:46 UTC 2023 - 12.4K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/internal/plugins/DefaultPluginManagerTest.groovy
when: manager.apply(rulesClass) then: 1 * target.applyRules(null, rulesClass) and: manager.hasPlugin("foo") } def "action is notified when rules plugin with id is applied by class"() { def action = Mock(Action) given: addPluginId("foo", rulesClass) manager.withPlugin("foo", action) when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 16.1K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/tasks/testing/AbstractTestTask.java
} /** * Adds a closure to be notified before a test is executed. A {@link TestDescriptor} instance is passed to the closure as a parameter. * * @param closure The closure to call. */ public void beforeTest(Closure closure) { addDispatchAsTestListener("beforeTest", closure); } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 25 18:49:01 UTC 2024 - 27.6K bytes - Viewed (0) -
src/os/signal/signal_test.go
for range sig { // Receive signals until the sender closes sig. } } func testCancel(t *testing.T, ignore bool) { // Ask to be notified on c1 when a SIGWINCH is received. c1 := make(chan os.Signal, 1) Notify(c1, syscall.SIGWINCH) defer Stop(c1) // Ask to be notified on c2 when a SIGHUP is received. c2 := make(chan os.Signal, 1) Notify(c2, syscall.SIGHUP) defer Stop(c2)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 15:34:56 UTC 2023 - 27.2K bytes - Viewed (0) -
src/runtime/sema.go
lockWithRank(&l.lock, lockRankNotifyList) s := l.head l.head = nil l.tail = nil // Update the next ticket to be notified. We can set it to the current // value of wait because any previous waiters are already in the list // or will notice that they have already been notified when trying to // add themselves to the list. atomic.Store(&l.notify, l.wait.Load()) unlock(&l.lock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 19K bytes - Viewed (0) -
testing/integ-test/src/integTest/groovy/org/gradle/integtests/TaskExecutionIntegrationTest.groovy
@UnsupportedWithConfigurationCache def taskCanAccessTaskGraph() { buildFile << """ boolean notified = false task a(dependsOn: 'b') { doLast { task -> assert notified assert gradle.taskGraph.hasTask(task) assert gradle.taskGraph.hasTask(':a')
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 25.7K bytes - Viewed (0)