- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 756 for Filter (0.18 sec)
-
internal/bucket/replication/replication_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 32.5K bytes - Viewed (0) -
guava/src/com/google/common/base/SmallCharMatcher.java
static final int MAX_SIZE = 1023; private final char[] table; private final boolean containsZero; private final long filter; private SmallCharMatcher(char[] table, long filter, boolean containsZero, String description) { super(description); this.table = table; this.filter = filter; this.containsZero = containsZero; } private static final int C1 = 0xcc9e2d51;
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Fri Feb 09 15:49:48 GMT 2024 - 4.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/QueryStringBuilder.java
stream(conditions.get(SearchRequestParams.AS_OCCURRENCE)) .of(stream -> stream.filter(this::isOccurrence).findFirst().ifPresent(q -> queryBuf.insert(0, q + ":"))); stream(conditions.get(SearchRequestParams.AS_Q)).of(stream -> stream .filter(q -> StringUtil.isNotBlank(q) && q.length() <= maxQueryLength).forEach(q -> queryBuf.append(' ').append(q)));
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 8.7K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/endpoint.go
} } return "unknown" } func (c *ConfigWriter) PrintEndpoints(filter EndpointFilter, outputFormat string) error { if c.configDump == nil { return fmt.Errorf("config writer has not been primed") } dump, err := c.retrieveSortedEndpointsSlice(filter) if err != nil { return err } marshaller := make(proto.MessageSlice, 0, len(dump)) for _, eds := range dump {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 5.6K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/AbstractNode.java
break; } } } return visitor.leave(this); } @Override public Node filter(Predicate<Node> filter) { List<Node> children = getChildren().stream().filter(filter).map(n -> n.filter(filter)).collect(Collectors.toList()); return new WrapperNode(this, Collections.unmodifiableList(children)); } @Override
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Mar 25 10:50:01 GMT 2024 - 2.4K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/services.go
} // PrintServiceSummary prints a summary of the relevant services in the config dump to the ConfigWriter stdout func (c *ConfigWriter) PrintServiceSummary(filter ServiceFilter) error { w := c.tabwriter() zDump := c.ztunnelDump svcs := slices.Filter(maps.Values(zDump.Services), filter.Verify) slices.SortFunc(svcs, func(a, b *ZtunnelService) int { if r := cmp.Compare(a.Namespace, b.Namespace); r != 0 { return r }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/QueryProcessor.java
} queryCommandMap.put(name, queryCommand); } public void addFilter(final Filter filter) { filterList.add(filter); createFilterChain(); } protected void createFilterChain() { FilterChain chain = createDefaultFilterChain(); for (final Filter element : filterList) { chain = appendFilterChain(element, chain); } filterChain = chain;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 3.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/filter/EncodingFilter.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.filter; import java.io.IOException; import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import javax.servlet.Filter; import javax.servlet.FilterChain; import javax.servlet.FilterConfig;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6.9K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/artifact/resolver/filter/OrArtifactFilter.java
public OrArtifactFilter() { this.filters = new LinkedHashSet<>(); } public OrArtifactFilter(Collection<ArtifactFilter> filters) { this.filters = new LinkedHashSet<>(filters); } public boolean include(Artifact artifact) { for (ArtifactFilter filter : filters) { if (filter.include(artifact)) { return true; } }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Sep 06 11:28:54 GMT 2023 - 2.1K bytes - Viewed (0) -
internal/pubsub/pubsub.go
defer ps.RUnlock() for _, sub := range ps.subs { if sub.types.Contains(Mask(item.Mask())) && (sub.filter == nil || sub.filter(item)) { select { case sub.ch <- item: default: } } } } // Subscribe - Adds a subscriber to pubsub system func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error { totalSubs := atomic.AddInt32(&ps.numSubscribers, 1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0)