- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for _popper (0.12 sec)
-
guava-testlib/src/com/google/common/testing/AbstractPackageSanityTests.java
} } abstract static class Chopper { final Chopper or(Chopper you) { Chopper i = this; return new Chopper() { @Override Optional<String> chop(String str) { return i.chop(str).or(you.chop(str)); } }; } abstract Optional<String> chop(String str); static Chopper suffix(String suffix) { return new Chopper() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 17.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/AbstractPackageSanityTests.java
} } abstract static class Chopper { final Chopper or(Chopper you) { Chopper i = this; return new Chopper() { @Override Optional<String> chop(String str) { return i.chop(str).or(you.chop(str)); } }; } abstract Optional<String> chop(String str); static Chopper suffix(String suffix) { return new Chopper() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 17.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r70/TestDisplayNameJUnit5CrossVersionSpec.groovy
test("throwsExceptionWhenPopped()") { operationDisplayName "throws EmptyStackException when popped" testDisplayName "throws EmptyStackException when popped" } testClass("org.example.TestingAStackDemo\$WhenNew\$AfterPushing") {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 18.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval.go
// source can change over time - i.e. for watchCache circular // buffer. When the circular buffer is full and an event needs // to be popped off, watchCache::startIndex is incremented. In // this case, an interval tracking that popped event is valid // only if it has already been copied to its internal buffer. // However, for efficiency we perform that lazily and we mark
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 8.2K bytes - Viewed (0) -
src/sync/pool_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 8K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
// Simulate a pod being popped by the scheduler, // At this time, unschedulable pod should be popped. p1, err := q.Pop(logger) if err != nil { t.Errorf("Error while popping the head of the queue: %v", err) } if p1.Pod != unschedulablePod { t.Errorf("Expected that test-pod-unscheduled was popped, got %v", p1.Pod.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
internal/ioutil/ioutil.go
func NewDeadlineWorker(timeout time.Duration) *DeadlineWorker { dw := &DeadlineWorker{ timeout: timeout, } return dw } // Run runs the given function, passing it a stopper channel. If the deadline passes before // the function finishes executing, Run returns context.DeadlineExceeded to the caller. // channel so that the work function can attempt to exit gracefully.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 10.2K bytes - Viewed (0) -
src/go/ast/commentmap.go
s.pop(n.Pos()) *s = append((*s), n) } // pop pops all nodes that appear lexically before pos // (i.e., whose lexical extent has ended before or at pos). // It returns the last node popped. func (s *nodeStack) pop(pos token.Pos) (top Node) { i := len(*s) for i > 0 && (*s)[i-1].End() <= pos { top = (*s)[i-1] i-- } *s = (*s)[0:i] return top }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
// are popped from this heap before the scheduler looks at activeQ podBackoffQ *heap.Heap // unschedulablePods holds pods that have been tried and determined unschedulable. unschedulablePods *UnschedulablePods // schedulingCycle represents sequence number of scheduling cycle and is incremented // when a pod is popped. schedulingCycle int64
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
go w.processInterval(ctx, intervalFromEvents(initEvents), 0) watchInitializationSignal.Wait() // note that we can add three events even though the chanSize is two because // one event has been popped off from the input chan if !w.add(&watchCacheEvent{Object: makePod(5), ResourceVersion: 5}, time.NewTimer(1*time.Second)) { t.Fatal("failed adding an even to the watcher") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0)