Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 767 for Filler (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top