- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 132 for watcher (0.08 seconds)
-
cmd/iam.go
} const maxDurationSecondsForLog = 5 func (sys *IAMSys) periodicRoutines(ctx context.Context, baseInterval time.Duration) { // Watch for IAM config changes for iamStorageWatcher. watcher, isWatcher := sys.store.IAMStorageAPI.(iamStorageWatcher) if isWatcher { go func() { ch := watcher.watch(ctx, iamConfigPrefix) for event := range ch { if err := sys.loadWatchedEvent(ctx, event); err != nil { // we simply log errors
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 76.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
private final EventBus bus; private final List<StringCatcher> catchers; Registrator(EventBus bus, List<StringCatcher> catchers) { this.bus = bus; this.catchers = catchers; } @Override public void run() { StringCatcher catcher = new StringCatcher(); bus.register(catcher); catchers.add(catcher); } } /** * A collector for DeadEvents.Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 11.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/eventbus/EventBusTest.java
private final EventBus bus; private final List<StringCatcher> catchers; Registrator(EventBus bus, List<StringCatcher> catchers) { this.bus = bus; this.catchers = catchers; } @Override public void run() { StringCatcher catcher = new StringCatcher(); bus.register(catcher); catchers.add(catcher); } } /** * A collector for DeadEvents.Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 11.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/crawler/rule/CrawlerRuleMimeTypePatternTest.java
assertTrue(pattern.matcher("application/x-lha").matches()); assertTrue(pattern.matcher("application/x-lha-compressed").matches()); } @Test public void test_fsFileRulePattern_xmlTypes() { Pattern pattern = Pattern.compile(FS_FILE_RULE_PATTERN); assertTrue(pattern.matcher("application/xml").matches());
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Feb 04 14:24:39 GMT 2026 - 8.7K bytes - Click Count (0) -
guava/src/com/google/common/base/CharMatcher.java
return new Negated(this); } /** * Returns a matcher that matches any character matched by both this matcher and {@code other}. */ public CharMatcher and(CharMatcher other) { return new And(this, other); } /** * Returns a matcher that matches any character matched by either this matcher or {@code other}. */ public CharMatcher or(CharMatcher other) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 54.4K bytes - Click Count (0) -
build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractBinaryCompatibilityTest.kt
inline fun <reified T> inAnyOrder(items: List<T>): Matcher<Iterable<T>> = inAnyOrder(items.toTypedArray()) /** * Matcher checking each item is present exactly once in a given iterable, but an any position, * and that there are no unexpected items. */ private fun <T> inAnyOrder(items: Array<out T>): Matcher<Iterable<T>> = Matchers.containsInAnyOrder(*items)
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Mon Jan 19 11:30:48 GMT 2026 - 18.3K bytes - Click Count (0) -
android/guava/src/com/google/common/base/CharMatcher.java
return new Negated(this); } /** * Returns a matcher that matches any character matched by both this matcher and {@code other}. */ public CharMatcher and(CharMatcher other) { return new And(this, other); } /** * Returns a matcher that matches any character matched by either this matcher or {@code other}. */ public CharMatcher or(CharMatcher other) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 53.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/PathMappingHelper.java
} /** * Creates a path matcher function for path mapping. * * @param matcher the regex matcher * @param replacement the replacement string * @return the path matcher function */ public BiFunction<String, Matcher, String> createPathMatcher(final Matcher matcher, final String replacement) { // for PathMappingCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 9.5K bytes - Click Count (0) -
.teamcity/scripts/CheckWrapper.java
throw new IllegalStateException("Malformed distributionUrl line: " + distributionUrl); } String url = distributionUrl.substring(idx + 1).trim(); Matcher m = WRAPPER_VERSION_EXTRACT.matcher(url); if (!m.matches()) { throw new IllegalStateException("Could not extract wrapper version from distributionUrl: " + url); } return m.group(1); }
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Jan 20 03:53:25 GMT 2026 - 6.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/base/CharMatcherTest.java
assertFalse(matcher.matches(s.charAt(0))); assertFalse(matcher.apply(s.charAt(0))); assertEquals(-1, matcher.indexIn(s)); assertEquals(-1, matcher.indexIn(s, 0)); assertEquals(-1, matcher.indexIn(s, 1)); assertEquals(-1, matcher.lastIndexIn(s)); assertFalse(matcher.matchesAnyOf(s)); assertFalse(matcher.matchesAllOf(s)); assertTrue(matcher.matchesNoneOf(s));
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 32.4K bytes - Click Count (0)