- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 767 for Filler (0.06 sec)
-
cmd/batch-expire.go
// Only parse object tags if tags filter is specified. var tagMap map[string]string if len(obj.UserTags) != 0 { t, err := tags.ParseObjectTags(obj.UserTags) if err != nil { return false } tagMap = t.ToMap() } for _, kv := range ef.Tags { // Object (version) must match all tags specified in // the filter var match bool for t, v := range tagMap {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 18 17:59:03 UTC 2024 - 21.9K bytes - Viewed (0) -
samples/tlssurvey/src/main/kotlin/okhttp3/survey/Clients.kt
}, ) } fun historicOkHttp(version: String): Client { val enabled = FileSystem.RESOURCES.read("okhttp_$version.txt".toPath()) { this.readUtf8().lines().filter { it.isNotBlank() }.map { SuiteId(id = null, name = it.trim()) } } return Client( userAgent = "OkHttp", version = version, enabled = enabled, ) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Apr 02 01:44:15 UTC 2024 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/MultisetsCollectionTest.java
CollectionFeature.KNOWN_ORDER, CollectionFeature.SUPPORTS_ADD, CollectionFeature.SUPPORTS_REMOVE) .named("Multiset.filter[Multiset, Predicate]") .createTestSuite()); return suite; } private static TestStringMultisetGenerator unmodifiableMultisetGenerator() { return new TestStringMultisetGenerator() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 9.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
} final Set<Throwable> getOrInitSeenExceptions() { /* * The initialization of seenExceptions has to be more complicated than we'd like. The simple * approach would be for each caller CAS it from null to a Set populated with its exception. But * there's another race: If the first thread fails with an exception and a second thread * immediately fails with the same exception: *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/util/FessCrawlerConfig.java
return ComponentUtil.getFessConfig().getIndexDocumentCrawlerIndex() + ".data"; } @Override public String getFilterIndex() { return ComponentUtil.getFessConfig().getIndexDocumentCrawlerIndex() + ".filter"; } @Override public int getQueueShards() { return ComponentUtil.getFessConfig().getIndexDocumentCrawlerQueueNumberOfShardsAsInteger(); } @Override
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 2.1K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultLifecycleRegistry.java
List<String> computed = allPhases.stream().filter(s -> !s.startsWith("$")).collect(Collectors.toList()); List<String> given = lifecycle.orderedPhases().orElse(null); if (given != null) { if (given.size() != computed.size()) { Set<String> s1 = given.stream().filter(s -> !computed.contains(s)).collect(Collectors.toSet());
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 19.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/user/cbean/cq/bs/BsGroupCQ.java
bool((must, should, mustNot, filter) -> { filteredLambda.callback(must, filter); }, opLambda); } public void not(OperatorCall<GroupCQ> notLambda) { not(notLambda, null); } public void not(final OperatorCall<GroupCQ> notLambda, final ConditionOptionCall<BoolQueryBuilder> opLambda) { bool((must, should, mustNot, filter) -> notLambda.callback(mustNot), opLambda); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 20K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/dataconfig/ApiAdminDataconfigAction.java
body.permissions = stream(entity.getPermissions()).get(stream -> stream.map(s -> permissionHelper.decode(s)) .filter(StringUtil::isNotBlank).distinct().collect(Collectors.joining("\n"))); body.virtualHosts = stream(entity.getVirtualHosts()) .get(stream -> stream.filter(StringUtil::isNotBlank).distinct().map(String::trim).collect(Collectors.joining("\n"))); return body; }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 7K bytes - Viewed (0) -
internal/logger/logger.go
f = strings.TrimPrefix(filepath.ToSlash(f), filepath.ToSlash(trimString)) } return filepath.FromSlash(f) } func getSource(level int) string { pc, file, lineNumber, ok := runtime.Caller(level) if ok { // Clean up the common prefixes file = trimTrace(file) _, funcName := filepath.Split(runtime.FuncForPC(pc).Name()) return fmt.Sprintf("%v:%v:%v()", file, lineNumber, funcName) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 22 09:43:48 UTC 2024 - 12.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
} responseBody.close() assertEquals(if (connectionType == H2) 1 else 0, client.connectionPool.connectionCount()) cancelLatch.await() val events = listener.eventSequence.filter { isConnectionEvent(it) }.map { it.name } listener.clearAllEvents() assertThat(events).startsWith("CallStart", "ConnectStart", "ConnectEnd", "ConnectionAcquired") if (cancelMode == CANCEL) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.9K bytes - Viewed (0)