appear - Code Search

internal/pubsub/pubsub.go

		return fmt.Errorf("the limit of `%d` subscribers is reached", ps.maxSubscribers)
	}
	ps.Lock()
	defer ps.Unlock()

	sub := &Sub[T]{ch: subCh, types: Mask(mask.Mask()), filter: filter}
	ps.subs = append(ps.subs, sub)

	// We hold a lock, so we are safe to update
	combined := Mask(atomic.LoadUint64(&ps.types))
	combined.Merge(Mask(mask.Mask()))
	atomic.StoreUint64(&ps.types, uint64(combined))

	go func() {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue Feb 06 16:57:30 GMT 2024

- 5.2K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/collect/HashMultimap.java

    return new HashMultimap<>(expectedKeys, expectedValuesPerKey);
  }

  /**
   * Constructs a {@code HashMultimap} with the same mappings as the specified multimap. If a
   * key-value mapping appears multiple times in the input multimap, it only appears once in the
   * constructed multimap.
   *
   * <p>You may also consider the equivalent {@code
   * MultimapBuilder.hashKeys().hashSetValues().build(multimap)}, which provides more control over

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Fri Dec 05 23:15:58 GMT 2025

- 5.8K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/base/Joiner.java

        appendable.append(joiner.toString(entry.getKey()));
        appendable.append(keyValueSeparator);
        appendable.append(joiner.toString(entry.getValue()));
        while (parts.hasNext()) {
          appendable.append(joiner.separator);
          Entry<?, ?> e = parts.next();
          appendable.append(joiner.toString(e.getKey()));
          appendable.append(keyValueSeparator);

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 17 20:26:29 GMT 2025

- 19.3K bytes

- Click Count (0)

github.com/apache/maven

compat/maven-artifact/src/main/java/org/apache/maven/artifact/versioning/Restriction.java

        StringBuilder buf = new StringBuilder();

        buf.append(isLowerBoundInclusive() ? '[' : '(');
        if (getLowerBound() != null) {
            buf.append(getLowerBound().toString());
        }
        buf.append(',');
        if (getUpperBound() != null) {
            buf.append(getUpperBound().toString());
        }
        buf.append(isUpperBoundInclusive() ? ']' : ')');

        return buf.toString();

Created: Sun Apr 05 03:35:12 GMT 2026

- Last Modified: Fri Jun 06 14:28:57 GMT 2025

- 4.3K bytes

- Click Count (0)

github.com/apache/maven

impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/CleanArgument.java

            // buffer, then append it with a preceding space...again, not sure what else to
            // do other than collapse whitespace.
            // NOTE: The case of a trailing quote is handled by nullifying the arg buffer.
            if (!addedToBuffer) {
                if (currentArg != null) {
                    currentArg.append(' ').append(arg);
                } else {

Created: Sun Apr 05 03:35:12 GMT 2026

- Last Modified: Fri Mar 28 12:11:25 GMT 2025

- 3.4K bytes

- Click Count (0)

github.com/square/okhttp

samples/static-server/src/main/java/okhttp3/sample/SampleServer.java

    StringBuilder response = new StringBuilder();
    response.append(String.format("<html><head><title>%s</title></head><body>", basePath));
    response.append(String.format("<h1>%s</h1>", basePath));
    for (String file : directory.list()) {
      response.append(String.format("<div class='file'><a href='%s'>%s</a></div>",
          basePath + file, file));
    }
    response.append("</body></html>");

    return new MockResponse()

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Wed Mar 11 02:37:00 GMT 2026

- 5.3K bytes

- Click Count (0)

github.com/apache/maven

compat/maven-model-builder/src/main/java/org/apache/maven/model/interpolation/reflection/ClassMap.java

                } else if (parameterType.equals(Float.TYPE)) {
                    methodKey.append("java.lang.Float");
                } else if (parameterType.equals(Integer.TYPE)) {
                    methodKey.append("java.lang.Integer");
                } else if (parameterType.equals(Long.TYPE)) {
                    methodKey.append("java.lang.Long");

Created: Sun Apr 05 03:35:12 GMT 2026

- Last Modified: Sat Apr 05 11:52:05 GMT 2025

- 13.5K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/base/MoreObjects.java

                ? !omitNullValuesSnapshot
                : (!omitEmptyValuesSnapshot || !isEmpty(value)))) {
          builder.append(nextSeparator);
          nextSeparator = ", ";

          if (valueHolder.name != null) {
            builder.append(valueHolder.name).append('=');
          }
          if (value != null && value.getClass().isArray()) {
            Object[] objectArray = {value};

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Feb 05 17:38:41 GMT 2026

- 16.7K bytes

- Click Count (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/timer/SystemMonitorTargetTest.java

        Method[] methods = SystemMonitorTarget.class.getDeclaredMethods();

        for (Method method : methods) {
            if (method.getName().startsWith("append") && !method.getName().equals("append")) {
                assertTrue("Private append methods should be private: " + method.getName(),
                        java.lang.reflect.Modifier.isPrivate(method.getModifiers()));
            }
        }
    }

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Mar 13 23:01:26 GMT 2026

- 9.2K bytes

- Click Count (0)

github.com/minio/minio

internal/grid/debug.go

			return nil, err
		}
		m := mux.NewRouter()
		m.Handle(RoutePath, manager.Handler(dummyRequestValidate))
		res.Managers = append(res.Managers, manager)
		res.Servers = append(res.Servers, startHTTPServer(listeners[i], m))
		res.Listeners = append(res.Listeners, listeners[i])
		res.Mux = append(res.Mux, m)
	}
	close(ready)
	for _, m := range res.Managers {
		for _, remote := range m.Targets() {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 4.4K bytes

- Click Count (0)

Search Options